boolean stillPresent = this.connectionDescriptors.removeConnection(existingDescriptor);
<BUG>if (!stillPresent) {
return;</BUG>
}
<BUG>LOG.info("DISCONNECT client <{}> finished", clientID);
}</BUG>
private boolean removeSubscriptions(ConnectionDescriptor descriptor, String clientID) {
final boolean success = descriptor.assignState(ConnectionState.ESTABLISHED, ConnectionState.SUBSCRIPTIONS_REMOVED);
if (!success) {
return false;

boolean stillPresent = this.connectionDescriptors.removeConnection(existingDescriptor);
if (!stillPresent) {
LOG.warn("Another descriptor has been inserted. MqttClientId = {}.", clientID);
return;
}
LOG.info("The DISCONNECT message has been processed. MqttClientId = {}.", clientID);
}
private boolean removeSubscriptions(ConnectionDescriptor descriptor, String clientID) {
final boolean success = descriptor.assignState(ConnectionState.ESTABLISHED, ConnectionState.SUBSCRIPTIONS_REMOVED);
if (!success) {
return false;
