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,