commit | 54c3b9d2987641fbf8d61e33a7a30b80e8ed423c | [log] [tgz] |
---|---|---|
author | Timothy Bish <tabish121@gmail.com> | Mon Aug 03 18:25:00 2015 -0400 |
committer | Timothy Bish <tabish121@gmail.com> | Mon Aug 03 18:25:00 2015 -0400 |
tree | 9de83ae8584ced996bba610e16118edd35282153 | |
parent | 44bb92593444ee3bf22df32b16bcda96128dff4a [diff] |
Update the values of last delivered sequence defaults to match JMS client.
diff --git a/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp b/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp index cba5882..5858385 100644 --- a/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp +++ b/activemq-cpp/src/main/activemq/core/ActiveMQConnection.cpp
@@ -717,7 +717,7 @@ } } - long long lastDeliveredSequenceId = 0; + long long lastDeliveredSequenceId = -1; // Get the complete list of active sessions. try {
diff --git a/activemq-cpp/src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp b/activemq-cpp/src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp index 0329d61..f486964 100644 --- a/activemq-cpp/src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp +++ b/activemq-cpp/src/main/activemq/core/kernels/ActiveMQSessionKernel.cpp
@@ -203,7 +203,7 @@ producerIds(), producerSequenceIds(), consumerIds(), - lastDeliveredSequenceId(0) { + lastDeliveredSequenceId(-2) { if (id == NULL || connection == NULL) { throw ActiveMQException( @@ -225,8 +225,6 @@ throw; } - this->closed.set(false); - this->lastDeliveredSequenceId = -1; this->config->sessionAsyncDispatch = connection->isAlwaysSessionAsync(); // Create a Transaction object