activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject git commit: https://issues.apache.org/jira/browse/AMQCPP-545
Date Wed, 18 Jun 2014 18:14:14 GMT
Repository: activemq-cpp
Updated Branches:
  refs/heads/trunk 91f5566f0 -> 352475374


https://issues.apache.org/jira/browse/AMQCPP-545

Only timeout on Message send operations.  

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

Branch: refs/heads/trunk
Commit: 352475374fd96ac560f56ec6a47aba817f3cba1d
Parents: 91f5566
Author: Timothy Bish <tabish121@gmail.com>
Authored: Wed Jun 18 14:13:59 2014 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Wed Jun 18 14:13:59 2014 -0400

----------------------------------------------------------------------
 .../src/main/activemq/transport/failover/FailoverTransport.cpp     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-cpp/blob/35247537/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
----------------------------------------------------------------------
diff --git a/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp b/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
index 7cad404..1c35e9e 100644
--- a/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
+++ b/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
@@ -437,7 +437,7 @@ void FailoverTransport::oneway(const Pointer<Command> command) {
 
                     while (transport == NULL && !this->impl->closed &&
this->impl->connectionFailure == NULL) {
                         long long end = System::currentTimeMillis();
-                        if (this->impl->timeout > 0 && (end - start >
this->impl->timeout)) {
+                        if (command->isMessage() && this->impl->timeout
> 0 && (end - start > this->impl->timeout)) {
                             timedout = true;
                             break;
                         }


Mime
View raw message