未验证 提交 305fa472 编写于 作者: X Xin Wang 提交者: GitHub

[IOTDB-785] Disable anonymous access MQTT service (#1447)

* [IOTDB-503] Add checkTimeseriesExists for session
* [IOTDB-785] Disable anonymous access MQTT service
上级 0e2d8387
......@@ -77,6 +77,8 @@ public class MQTTService implements IService {
properties.setProperty(BrokerConstants.PORT_PROPERTY_NAME, String.valueOf(iotDBConfig.getMqttPort()));
properties.setProperty(BrokerConstants.BROKER_INTERCEPTOR_THREAD_POOL_SIZE, String.valueOf(iotDBConfig.getMqttHandlerPoolSize()));
properties.setProperty(BrokerConstants.IMMEDIATE_BUFFER_FLUSH_PROPERTY_NAME, "true");
properties.setProperty(BrokerConstants.ALLOW_ANONYMOUS_PROPERTY_NAME, "false");
properties.setProperty(BrokerConstants.ALLOW_ZERO_BYTE_CLIENT_ID_PROPERTY_NAME, "true");
properties.setProperty(BrokerConstants.NETTY_MAX_BYTES_PROPERTY_NAME, String.valueOf(iotDBConfig.getMqttMaxMessageSize()));
return new MemoryConfig(properties);
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册