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

This closes #2597

This commit is contained in:
Justin Bertram 2019-04-01 09:23:16 -05:00
parent 82fe0e5894 34c8ed2adb
commit affb6a4cc4
1 changed files with 27 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
artemis-jms-server/src/main/java/org/apache/activemq/artemis/jms/bridge/impl/JMSBridgeImpl.java
View File

@ -533,12 +533,34 @@ public final class JMSBridgeImpl implements JMSBridge {
}
}
private void stopSessionFailover() {
XASession xaSource = (XASession) sourceSession;
XASession xaTarget = (XASession) targetSession;
private static void releaseCommunications(Session session, String sessionName) {
final XASession xaSession = (XASession) session;
((ClientSessionInternal) xaSource.getXAResource()).getSessionContext().releaseCommunications();
((ClientSessionInternal) xaTarget.getXAResource()).getSessionContext().releaseCommunications();
if (xaSession.getXAResource() instanceof ClientSessionInternal) {
try {
((ClientSessionInternal) xaSession.getXAResource()).getSessionContext().releaseCommunications();
} catch (Throwable t) {
ActiveMQJMSBridgeLogger.LOGGER.warnf(t, "Cannot release communications on %s", sessionName);
}
} else {
if (ActiveMQJMSBridgeLogger.LOGGER.isTraceEnabled()) {
ActiveMQJMSBridgeLogger.LOGGER.tracef("Cannot cast XAResource of %s to ClientSessionInternal and release communications: found class %s",
sessionName, xaSession.getClass().getCanonicalName());
}
}
}
private void stopSessionFailover() {
try {
releaseCommunications(sourceSession, "sourceSession");
} catch (Throwable t) {
ActiveMQJMSBridgeLogger.LOGGER.error("cannot release communications on sourceSession ", t);
}
try {
releaseCommunications(targetSession, "targetSession");
} catch (Throwable t) {
ActiveMQJMSBridgeLogger.LOGGER.error("cannot release communications on targetSession ", t);
}
}
@Override