You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2017/06/15 21:13:44 UTC
activemq git commit: NO-JIRA update the AMQP tests to use the client
close timeout
Repository: activemq
Updated Branches:
refs/heads/master 3fd37439f -> ce551cf97
NO-JIRA update the AMQP tests to use the client close timeout
Use the client built in close timeout instead of the executor which can
leave threads running and causes the tests to take much longer than
needed.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/ce551cf9
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/ce551cf9
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/ce551cf9
Branch: refs/heads/master
Commit: ce551cf97d95fbed89ebecf10c40a5060d7b756a
Parents: 3fd3743
Author: Timothy Bish <ta...@gmail.com>
Authored: Thu Jun 15 17:13:32 2017 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Thu Jun 15 17:13:32 2017 -0400
----------------------------------------------------------------------
.../transport/amqp/AmqpTestSupport.java | 4 ---
.../transport/amqp/JMSClientContext.java | 1 +
.../transport/amqp/JMSClientTestSupport.java | 33 ++------------------
3 files changed, 4 insertions(+), 34 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/ce551cf9/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
index 86402dc..69d1998 100644
--- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
+++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/AmqpTestSupport.java
@@ -25,8 +25,6 @@ import java.util.ArrayList;
import java.util.List;
import java.util.Set;
import java.util.Vector;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
import javax.jms.Connection;
import javax.jms.Destination;
@@ -69,8 +67,6 @@ public class AmqpTestSupport {
protected static final Logger LOG = LoggerFactory.getLogger(AmqpTestSupport.class);
- protected ExecutorService testService = Executors.newSingleThreadExecutor();
-
protected BrokerService brokerService;
protected Vector<Throwable> exceptions = new Vector<>();
protected int numberOfMessages;
http://git-wip-us.apache.org/repos/asf/activemq/blob/ce551cf9/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientContext.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientContext.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientContext.java
index f249e7c..1789792 100644
--- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientContext.java
+++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientContext.java
@@ -215,6 +215,7 @@ public class JMSClientContext {
factory.setForceSyncSend(syncPublish);
factory.setTopicPrefix("topic://");
factory.setQueuePrefix("queue://");
+ factory.setCloseTimeout(60000);
return factory;
}
http://git-wip-us.apache.org/repos/asf/activemq/blob/ce551cf9/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTestSupport.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTestSupport.java b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTestSupport.java
index 8408652..a5c1ae5 100644
--- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTestSupport.java
+++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTestSupport.java
@@ -18,11 +18,6 @@ package org.apache.activemq.transport.amqp;
import java.net.URI;
import java.net.URISyntaxException;
-import java.util.concurrent.Callable;
-import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.TimeoutException;
import javax.jms.Connection;
import javax.jms.JMSException;
@@ -33,40 +28,18 @@ public class JMSClientTestSupport extends AmqpTestSupport {
protected Connection connection;
- private Thread connectionCloseThread;
-
@Override
@After
public void tearDown() throws Exception {
- Future<Boolean> future = testService.submit(new CloseConnectionTask());
try {
LOG.debug("tearDown started.");
- future.get(60, TimeUnit.SECONDS);
- } catch (TimeoutException e) {
- if (connectionCloseThread != null) {
- connectionCloseThread.interrupt();;
- }
-
- testService.shutdownNow();
- testService = Executors.newSingleThreadExecutor();
- throw new Exception("CloseConnection timed out");
- } finally {
- connectionCloseThread = null;
- connection = null;
- super.tearDown();
- }
- }
-
- public class CloseConnectionTask implements Callable<Boolean> {
- @Override
- public Boolean call() throws Exception {
if (connection != null) {
- connectionCloseThread = Thread.currentThread();
LOG.debug("in CloseConnectionTask.call(), calling connection.close()");
connection.close();
}
-
- return Boolean.TRUE;
+ } finally {
+ connection = null;
+ super.tearDown();
}
}