diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2015-03-02 14:09:25 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2015-03-02 14:09:25 +0000 |
| commit | e274c8f94e7bb9e533a9ed0393b71b590a591cc3 (patch) | |
| tree | 0172bb238d307bbf340484c1aded326047033ee7 /qpid/java/systests/src | |
| parent | 67a9864ed236ed085e263beaea7bae2c52522331 (diff) | |
| download | qpid-python-e274c8f94e7bb9e533a9ed0393b71b590a591cc3.tar.gz | |
Make management close session async
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1663314 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/systests/src')
2 files changed, 6 insertions, 10 deletions
diff --git a/qpid/java/systests/src/test/java/org/apache/qpid/client/AMQQueueDeferredOrderingTest.java b/qpid/java/systests/src/test/java/org/apache/qpid/client/AMQQueueDeferredOrderingTest.java index cdd5e13870..0acdd2509d 100644 --- a/qpid/java/systests/src/test/java/org/apache/qpid/client/AMQQueueDeferredOrderingTest.java +++ b/qpid/java/systests/src/test/java/org/apache/qpid/client/AMQQueueDeferredOrderingTest.java @@ -20,12 +20,6 @@ */ package org.apache.qpid.client; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import org.apache.qpid.framing.AMQShortString; -import org.apache.qpid.test.utils.QpidBrokerTestCase; - import javax.jms.Connection; import javax.jms.Message; import javax.jms.MessageConsumer; @@ -33,6 +27,12 @@ import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import org.apache.qpid.framing.AMQShortString; +import org.apache.qpid.test.utils.QpidBrokerTestCase; + public class AMQQueueDeferredOrderingTest extends QpidBrokerTestCase { private Connection con; @@ -122,8 +122,6 @@ public class AMQQueueDeferredOrderingTest extends QpidBrokerTestCase { Message msg = consumer.receive(3000); - _logger.debug("KWDEBUG got " + msg); - assertNotNull("Message " + i + " should not be null", msg); assertTrue("Message " + i + " should be a text message", msg instanceof TextMessage); assertEquals("Message content " + i + " does not match expected", Integer.toString(i), ((TextMessage) msg).getText()); diff --git a/qpid/java/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java b/qpid/java/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java index cf28895799..8a4e22783f 100644 --- a/qpid/java/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java +++ b/qpid/java/systests/src/test/java/org/apache/qpid/test/client/QueueBrowserAutoAckTest.java @@ -147,8 +147,6 @@ public class QueueBrowserAutoAckTest extends QpidBrokerTestCase assertEquals("Session reports Queue expectedDepth not as expected", expectedDepth, queueDepth); - getLogger().debug("KWDEBUG : About to check queue depth using browser"); - // Browse the queue to get a second opinion int msgCount = 0; |