Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-4714 mitigate NPE in FederatedQueueConsumerImpl MessageListener

This commit is contained in:
Justin Bertram 2024-04-04 14:51:10 -05:00 committed by clebertsuconic
parent da9695a5f6
commit 0fad7ece87
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/federation/FederatedQueueConsumerImpl.java
View File

@ -325,7 +325,10 @@ public class FederatedQueueConsumerImpl implements FederatedQueueConsumer, Sessi
} catch (Exception e) {
ActiveMQServerLogger.LOGGER.federationDispatchError(clientMessage.toString(), e);
try {
clientSession.rollback();
ClientSession localSession = clientSession;
if (localSession != null) {
localSession.rollback();
}
} catch (ActiveMQException e1) {
}
}