set client (!server) version on recreate session

hornetq · Feb 12, 2015 · 9cd524e · 9cd524e
1 parent deceb64
commit 9cd524e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...-core-client/src/main/java/org/hornetq/core/protocol/core/impl/HornetQSessionContext.java b/...-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,