enforce previously implicit assumption that link isnt being drained
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/68ee9f50 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/68ee9f50 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/68ee9f50 Branch: refs/heads/master Commit: 68ee9f50c5f621592d2d7f8331d39709f1d6d33c Parents: b581085 Author: Robert Gemmell <[email protected]> Authored: Tue Dec 9 11:34:29 2014 +0000 Committer: Robert Gemmell <[email protected]> Committed: Tue Dec 9 11:34:29 2014 +0000 ---------------------------------------------------------------------- .../test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/68ee9f50/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java index 8dd6792..0152cbf 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java @@ -789,6 +789,7 @@ public class TestAmqpPeer implements AutoCloseable final FlowMatcher flowMatcher = new FlowMatcher() .withLinkCredit(Matchers.greaterThanOrEqualTo(UnsignedInteger.valueOf(count))) + .withDrain(Matchers.anyOf(equalTo(false), nullValue())) .withNextIncomingId(Matchers.equalTo(UnsignedInteger.valueOf(nextIncomingId))); CompositeAmqpPeerRunnable composite = new CompositeAmqpPeerRunnable(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
