activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [1/2] activemq-6 git commit: Set client (!server) version on recreate session
Date Thu, 12 Feb 2015 20:40:57 GMT
Repository: activemq-6
Updated Branches:
  refs/heads/master cf6e19ead -> e2983e538


Set client (!server) version on recreate session


Project: http://git-wip-us.apache.org/repos/asf/activemq-6/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-6/commit/92103831
Tree: http://git-wip-us.apache.org/repos/asf/activemq-6/tree/92103831
Diff: http://git-wip-us.apache.org/repos/asf/activemq-6/diff/92103831

Branch: refs/heads/master
Commit: 92103831260ab0445bfb2c582a684a82ca892940
Parents: 33addb4
Author: Martyn Taylor <mtaylor@redhat.com>
Authored: Thu Feb 12 12:46:17 2015 +0000
Committer: Martyn Taylor <mtaylor@redhat.com>
Committed: Thu Feb 12 12:46:17 2015 +0000

----------------------------------------------------------------------
 .../activemq/core/protocol/core/impl/ActiveMQSessionContext.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-6/blob/92103831/activemq-core-client/src/main/java/org/apache/activemq/core/protocol/core/impl/ActiveMQSessionContext.java
----------------------------------------------------------------------
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 17632c4..c1ec157 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,


Mime
View raw message