diff options
author | Robert Gemmell <robbie@apache.org> | 2010-09-05 18:51:15 +0000 |
---|---|---|
committer | Robert Gemmell <robbie@apache.org> | 2010-09-05 18:51:15 +0000 |
commit | 2e7e6fed93a10f90fd38228ffb034d53450f2413 (patch) | |
tree | 385b1a8867980e095b179d18e3af623b06b9624a /java/client/src/test | |
parent | ba3c83a6b74d8145ece6930272b880260e613a3c (diff) | |
download | qpid-python-2e7e6fed93a10f90fd38228ffb034d53450f2413.tar.gz |
QPID-2418: updates to fix test failures when using the 0-10 client test profiles.
Use a transacted session when querying for queue counts following consumption, as the 0-10 client batches auto-acks asynchronously.
Always send the selector filter argument even if empty, to allow querying the brokers via 0-10 to detect whether the selector is being added/removed/modified at subscribe time.
Enable the Java broker to perform argument matching during the 0-10 isBound check.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@992856 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client/src/test')
-rw-r--r-- | java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java b/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java index f7a37e4894..47c0359b94 100644 --- a/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java +++ b/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java @@ -29,6 +29,7 @@ import org.apache.qpid.framing.FieldTable; import org.apache.qpid.AMQException; import javax.jms.*; + import java.util.Map; public class TestAMQSession extends AMQSession<BasicMessageConsumer_0_8, BasicMessageProducer_0_8> @@ -188,4 +189,10 @@ public class TestAMQSession extends AMQSession<BasicMessageConsumer_0_8, BasicMe protected void flushAcknowledgments() { } + + public boolean isQueueBound(String exchangeName, String queueName, + String bindingKey, Map<String, Object> args) throws JMSException + { + return false; + } } |