Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #1873

This commit is contained in:
Clebert Suconic 2018-02-20 23:54:09 -05:00
parent e5ef7d37ae 1f06ec07e6
commit 2180dc3b99
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTConnectionManager.java
View File

@ -76,6 +76,7 @@ public class MQTTConnectionManager {
session.setSessionState(getSessionState(clientId)); session.setSessionState(getSessionState(clientId));
String password = passwordInBytes == null ? null : new String(passwordInBytes, CharsetUtil.UTF_8); String password = passwordInBytes == null ? null : new String(passwordInBytes, CharsetUtil.UTF_8);
session.getConnection().setClientID(clientId);
ServerSessionImpl serverSession = createServerSession(username, password); ServerSessionImpl serverSession = createServerSession(username, password);
serverSession.start(); serverSession.start();
@ -93,7 +94,6 @@ public class MQTTConnectionManager {
session.getConnection().setConnected(true); session.getConnection().setConnected(true);
session.start(); session.start();
session.getConnection().setClientID(clientId);
session.getProtocolHandler().sendConnack(MqttConnectReturnCode.CONNECTION_ACCEPTED); session.getProtocolHandler().sendConnack(MqttConnectReturnCode.CONNECTION_ACCEPTED);
} }