|
|
|
@ -65,7 +65,7 @@ public class MqttTransportContext extends TransportContext { |
|
|
|
private SslHandler sslHandler; |
|
|
|
|
|
|
|
@Getter |
|
|
|
@Value("${transport.mqtt.msg_queue_size_per_device_limit:10000}") |
|
|
|
@Value("${transport.mqtt.msg_queue_size_per_device_limit:100}") |
|
|
|
private int messageQueueSizePerDeviceLimit; |
|
|
|
|
|
|
|
@Getter |
|
|
|
|