if unchecked exception is throw while running processSubscription then remove() will never be called

[windbender]

for example if m_authorizator.canRead() throws an unchecked exception, then this will bubble up to processSubscription and the execution pathway will never reach

boolean success = this.subscriptionInCourse.remove(executionKey, SubscriptionState.STORED);

Hence the broker would never be able to handle another subscription event from that executionKey again.