Repository: activemq-artemis Updated Branches: refs/heads/master 335381d19 -> 2d8c8d446
ARTEMIS-1187 Incompatible version when recreating a session with older server Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/8eb5ce9e Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/8eb5ce9e Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/8eb5ce9e Branch: refs/heads/master Commit: 8eb5ce9ebd67d2fe623fc42e9647e392d2dfdccc Parents: 335381d Author: Tomas Hofman <[email protected]> Authored: Mon May 29 12:27:09 2017 +0200 Committer: Clebert Suconic <[email protected]> Committed: Wed May 31 11:46:35 2017 -0400 ---------------------------------------------------------------------- .../artemis/core/protocol/core/impl/ActiveMQSessionContext.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/8eb5ce9e/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQSessionContext.java ---------------------------------------------------------------------- diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQSessionContext.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQSessionContext.java index f9af0b1..4b8bedb 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQSessionContext.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/protocol/core/impl/ActiveMQSessionContext.java @@ -687,7 +687,7 @@ public class ActiveMQSessionContext extends SessionContext { boolean autoCommitSends, boolean autoCommitAcks, boolean preAcknowledge) { - return new CreateSessionMessage(name, sessionChannel.getID(), VersionLoader.getVersion().getIncrementingVersion(), username, password, minLargeMessageSize, xa, autoCommitSends, autoCommitAcks, preAcknowledge, confirmationWindow, null); + return new CreateSessionMessage(name, sessionChannel.getID(), serverVersion, username, password, minLargeMessageSize, xa, autoCommitSends, autoCommitAcks, preAcknowledge, confirmationWindow, null); } @Override
