final ConnectionDescriptor existingDescriptor = this.connectionDescriptors.getConnection(clientID);
if (existingDescriptor == null) {
channel.close();
return;
}
<BUG>if (existingDescriptor.doesNotUseChannel(channel)) {
existingDescriptor.abort();</BUG>
return;
}
<BUG>if (!removeSubscriptions(existingDescriptor, clientID)) {
existingDescriptor.abort();</BUG>
return;

final ConnectionDescriptor existingDescriptor = this.connectionDescriptors.getConnection(clientID);
if (existingDescriptor == null) {
channel.close();
return;
