From 92103831260ab0445bfb2c582a684a82ca892940 Mon Sep 17 00:00:00 2001 From: Martyn Taylor Date: Thu, 12 Feb 2015 12:46:17 +0000 Subject: [PATCH] Set client (!server) version on recreate session --- .../core/protocol/core/impl/ActiveMQSessionContext.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java index 17632c4088..c1ec157429 100644 --- a/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java +++ b/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java @@ -99,6 +99,7 @@ import org.apache.activemq.spi.core.protocol.RemotingConnection; import org.apache.activemq.spi.core.remoting.Connection; import org.apache.activemq.spi.core.remoting.SessionContext; import org.apache.activemq.utils.TokenBucketLimiterImpl; +import org.apache.activemq.utils.VersionLoader; import static org.apache.activemq.core.protocol.core.impl.PacketImpl.DISCONNECT_CONSUMER; import static org.apache.activemq.core.protocol.core.impl.PacketImpl.EXCEPTION; @@ -628,7 +629,7 @@ public class ActiveMQSessionContext extends SessionContext { Packet createRequest = new CreateSessionMessage(name, sessionChannel.getID(), - getServerVersion(), + VersionLoader.getVersion().getIncrementingVersion(), username, password, minLargeMessageSize,