final boolean success = descriptor.assignState(ConnectionState.SUBSCRIPTIONS_REMOVED, ConnectionState.MESSAGES_DROPPED);
if (!success) {
return false;
}
if (descriptor.cleanSession) {
<BUG>LOG.debug("Removing messages in session's queue for client <{}>", clientID);
</BUG>
this.m_sessionsStore.dropQueue(clientID);
<BUG>LOG.debug("Removed messages in session for client's queue <{}>", clientID);
}</BUG>
return true;

final boolean success = descriptor.assignState(ConnectionState.SUBSCRIPTIONS_REMOVED, ConnectionState.MESSAGES_DROPPED);
if (!success) {
return false;
}
if (descriptor.cleanSession) {
LOG.debug("Removing messages of session. MqttClientId = {}.", descriptor.clientID);
this.m_sessionsStore.dropQueue(clientID);
LOG.debug("The messages of the session have been removed. MqttClientId = {}.", descriptor.clientID);
}
