182183184185186187188189190191192
if (result) { doAddRecoveredMessage(message); } } finally { msgContext.clear(); } return result; } public ActiveMQDestination getActiveMQDestination() {
682683684685686687688689690691692
} } finally { dispatchLock.readLock().unlock(); if (msgContext != null) { msgContext.clear(); } } } private final Runnable expireMessagesTask = new Runnable() {
413414415416417418419420421422423
if (!dispatchPolicy.dispatch(context, message, msgContext, consumers)) { onMessageWithNoConsumers(context, message); } } finally { msgContext.clear(); dispatchValve.decrement(); } } /**
189190191192193194195196197198199
} } } finally { msgContext.clear(); dispatchValve.turnOn(); } } public void removeSubscription(ConnectionContext context, Subscription sub) throws Exception {
256257258259260261262263264265266
msgContext.setMessageReference(node); dispatchPolicy.dispatch(context, node, msgContext, consumers); } } finally { msgContext.clear(); } } } finally { dispatchValve.turnOn();
470471472473474475476477478479480
msgContext.setMessageReference(node); dispatchPolicy.dispatch(context, node, msgContext, consumers); } finally { msgContext.clear(); dispatchValve.decrement(); } } private int calcHighestSubscriptionPriority() {
719720721722723724725726727728729
169170171172173174175176177178179
210211212213214215216217218219220
if (result) { doAddRecoveredMessage(message); } } finally { msgContext.clear(); } return result; } @Override