diff options
| author | Robert Gemmell <robbie@apache.org> | 2012-02-13 00:56:23 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2012-02-13 00:56:23 +0000 |
| commit | 99c38d6c25eb381ba856bf4f08899b931fb39af0 (patch) | |
| tree | f4bc28c5dec61778117d878bdc15d6f5a9462e83 /qpid/java/client/src/test | |
| parent | 7fc447475dd3d186e139ff708c512b18e36f1bc4 (diff) | |
| download | qpid-python-99c38d6c25eb381ba856bf4f08899b931fb39af0.tar.gz | |
QPID-3831: use AcquireMode=PRE_ACQUIRED when using server-side selectors and consuming from Queues. Remove unused method parameter for selector filter.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1243384 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/client/src/test')
| -rw-r--r-- | qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java | 2 | ||||
| -rw-r--r-- | qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java | 3 |
2 files changed, 2 insertions, 3 deletions
diff --git a/qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java b/qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java index 4bfbd3c726..028e2d5cc3 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/client/AMQSession_0_10Test.java @@ -276,7 +276,7 @@ public class AMQSession_0_10Test extends QpidTestCase { BasicMessageConsumer_0_10 consumer = session.createMessageConsumer(createDestination(), 1, 1, true, false, null, null, false, true); - session.sendConsume(consumer, new AMQShortString("test"), null, true, null, 1); + session.sendConsume(consumer, new AMQShortString("test"), null, true, 1); } catch (Exception e) { diff --git a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java index ecd8eb99d1..84d91ee57e 100644 --- a/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java +++ b/qpid/java/client/src/test/java/org/apache/qpid/test/unit/message/TestAMQSession.java @@ -29,7 +29,6 @@ import org.apache.qpid.client.BasicMessageProducer_0_8; import org.apache.qpid.client.failover.FailoverException; import org.apache.qpid.client.message.AMQMessageDelegateFactory; import org.apache.qpid.client.protocol.AMQProtocolHandler; -import org.apache.qpid.client.filter.MessageFilter; import org.apache.qpid.framing.AMQShortString; import org.apache.qpid.framing.FieldTable; @@ -125,7 +124,7 @@ public class TestAMQSession extends AMQSession_0_8 return false; } - public void sendConsume(BasicMessageConsumer_0_8 consumer, AMQShortString queueName, AMQProtocolHandler protocolHandler, boolean nowait, MessageFilter messageSelector, int tag) throws AMQException, FailoverException + public void sendConsume(BasicMessageConsumer_0_8 consumer, AMQShortString queueName, AMQProtocolHandler protocolHandler, boolean nowait, int tag) throws AMQException, FailoverException { } |