We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e6775d7 commit e49cda5Copy full SHA for e49cda5
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/ServerConsumerImpl.java
@@ -526,7 +526,13 @@ public void proceedDeliver(MessageReference reference) throws Exception {
526
}
527
} finally {
528
pendingDelivery.countDown();
529
- callback.afterDelivery();
+
530
+ // ensure the callback is still valid without blocking other threads
531
+ final SessionCallback localCallback = callback;
532
+ if (localCallback != null) {
533
+ localCallback.afterDelivery();
534
+ }
535
536
if (server.hasBrokerMessagePlugins()) {
537
server.callBrokerMessagePlugins(plugin -> plugin.afterDeliver(this, reference));
538
0 commit comments