You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2015/01/12 16:57:36 UTC

[2/2] qpid-jms git commit: Fix the close timeout check logic

Fix the close timeout check logic

Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/ded00c7a
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/ded00c7a
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/ded00c7a

Branch: refs/heads/master
Commit: ded00c7a93a3d4f2bc675e182023271838768895
Parents: 780492a
Author: Timothy Bish <ta...@gmail.com>
Authored: Mon Jan 12 10:57:03 2015 -0500
Committer: Timothy Bish <ta...@gmail.com>
Committed: Mon Jan 12 10:57:03 2015 -0500

----------------------------------------------------------------------
 .../org/apache/qpid/jms/provider/failover/FailoverProvider.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/ded00c7a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java
index c7c1227..256d635 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/failover/FailoverProvider.java
@@ -190,7 +190,7 @@ public class FailoverProvider extends DefaultProviderListener implements Provide
             });
 
             try {
-                if (this.closeTimeout >= 0) {
+                if (this.closeTimeout < 0) {
                     request.sync();
                 } else {
                     request.sync(closeTimeout, TimeUnit.MILLISECONDS);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org