You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2015/01/19 12:59:13 UTC
[3/3] qpid-jms git commit: perfom both group shutdowns in parallel
perfom both group shutdowns in parallel
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/2a4eecb6
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/2a4eecb6
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/2a4eecb6
Branch: refs/heads/master
Commit: 2a4eecb6275148ff6ddaabd885b3b5ac405f05ce
Parents: aa68714
Author: Robert Gemmell <ro...@apache.org>
Authored: Mon Jan 19 11:52:12 2015 +0000
Committer: Robert Gemmell <ro...@apache.org>
Committed: Mon Jan 19 11:52:12 2015 +0000
----------------------------------------------------------------------
.../java/org/apache/qpid/jms/test/netty/NettyEchoServer.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/2a4eecb6/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/netty/NettyEchoServer.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/netty/NettyEchoServer.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/netty/NettyEchoServer.java
index 3973f07..42bc535 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/netty/NettyEchoServer.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/netty/NettyEchoServer.java
@@ -90,11 +90,12 @@ public class NettyEchoServer implements AutoCloseable {
// Shut down all event loops to terminate all threads.
LOG.info("Shutting down boss group");
Future<?> bossFuture = bossGroup.shutdownGracefully(10, TIMEOUT, TimeUnit.MILLISECONDS);
+ LOG.info("Shutting down worker group");
+ Future<?> workerFuture = workerGroup.shutdownGracefully(10, TIMEOUT, TimeUnit.MILLISECONDS);
+
LOG.info("Awaiting boss group shutdown");
boolean bossShutdown = bossFuture.await(TIMEOUT + 500);
- LOG.info("Shutting down worker group");
- Future<?> workerFuture = workerGroup.shutdownGracefully(10, TIMEOUT, TimeUnit.MILLISECONDS);
LOG.info("Awaiting worker group shutdown");
boolean workerShutdown = workerFuture.await(TIMEOUT + 500);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org