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 22:46:47 UTC
[3/3] qpid-jms git commit: fix slow close.
fix slow close.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/e8e29b82
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/e8e29b82
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/e8e29b82
Branch: refs/heads/master
Commit: e8e29b820ee0bec54d0b2c2e2d27313d30c571af
Parents: d5970ca
Author: Timothy Bish <ta...@gmail.com>
Authored: Mon Jan 12 16:46:39 2015 -0500
Committer: Timothy Bish <ta...@gmail.com>
Committed: Mon Jan 12 16:46:39 2015 -0500
----------------------------------------------------------------------
.../apache/qpid/jms/provider/failover/FailoverProvider.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e8e29b82/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 06d3c9a..9d2a199 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
@@ -177,7 +177,9 @@ public class FailoverProvider extends DefaultProviderListener implements Provide
LOG.debug("Caught exception while closing connection");
} finally {
ThreadPoolUtils.shutdownGraceful(connectionHub);
- ThreadPoolUtils.shutdownGraceful(serializer);
+ if (serializer != null) {
+ serializer.shutdown();
+ }
request.onSuccess();
}
}
@@ -239,7 +241,7 @@ public class FailoverProvider extends DefaultProviderListener implements Provide
serializer.execute(pending);
}
- //TODO: decide if this handling is sufficient
+ // TODO: decide if this handling is sufficient
@Override
public void stop(final JmsResource resource, final AsyncResult request) throws IOException, JMSException {
checkClosed();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org