diff --git a/hornetq-core-client/src/main/java/org/hornetq/core/protocol/core/impl/HornetQSessionContext.java b/hornetq-core-client/src/main/java/org/hornetq/core/protocol/core/impl/HornetQSessionContext.java index 311e93781c4..6375752ef63 100644 --- a/hornetq-core-client/src/main/java/org/hornetq/core/protocol/core/impl/HornetQSessionContext.java +++ b/hornetq-core-client/src/main/java/org/hornetq/core/protocol/core/impl/HornetQSessionContext.java @@ -96,6 +96,7 @@ import org.hornetq.spi.core.remoting.Connection; import org.hornetq.spi.core.remoting.SessionContext; import org.hornetq.utils.TokenBucketLimiterImpl; +import org.hornetq.utils.VersionLoader; import static org.hornetq.core.protocol.core.impl.PacketImpl.DISCONNECT_CONSUMER; import static org.hornetq.core.protocol.core.impl.PacketImpl.EXCEPTION; @@ -627,7 +628,7 @@ public void recreateSession(final String username, { Packet createRequest = new CreateSessionMessage(name, sessionChannel.getID(), - getServerVersion(), + VersionLoader.getVersion().getIncrementingVersion(), username, password, minLargeMessageSize,