| | |
|---|
| | | |
|---|
| | | private final GenericObjectPool<MqttClient> pool; |
|---|
| | | |
|---|
| | | public MqttClientPool(String broker, String username, String password, int maxConnections) { |
|---|
| | | MqttClientPooledObjectFactory factory = new MqttClientPooledObjectFactory(broker, username, password); |
|---|
| | | public MqttClientPool(String broker, String username, String password, int maxConnections, boolean useMemoryPersistence) { |
|---|
| | | MqttClientPooledObjectFactory factory = new MqttClientPooledObjectFactory(broker, username, password, useMemoryPersistence); |
|---|
| | | GenericObjectPoolConfig<MqttClient> config = new GenericObjectPoolConfig<>(); |
|---|
| | | config.setMaxTotal(maxConnections); |
|---|
| | | config.setMaxIdle(maxConnections); |
|---|
