moquette
moquette copied to clipboard
if unchecked exception is throw while running processSubscription then remove() will never be called
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.