Repository: qpid-jms Updated Branches: refs/heads/master 63d56d282 -> 7a0439e43
update test to perform repeat send to observe continued use of link to the anonymous-relay Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/840d3f7e Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/840d3f7e Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/840d3f7e Branch: refs/heads/master Commit: 840d3f7e3fdddc68c5871eecc3c8d3581b68f152 Parents: 63d56d2 Author: Robert Gemmell <[email protected]> Authored: Wed Nov 12 09:45:42 2014 +0000 Committer: Robert Gemmell <[email protected]> Committed: Wed Nov 12 10:16:02 2014 +0000 ---------------------------------------------------------------------- .../apache/qpid/jms/integration/SessionIntegrationTest.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/840d3f7e/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java index ef4dcdd..ebd81b0 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SessionIntegrationTest.java @@ -166,17 +166,23 @@ public class SessionIntegrationTest extends QpidJmsTestCase { MessageProducer producer = session.createProducer(null); assertNotNull("Producer object was null", producer); - //Expect a new message sent on the above link to the anonymous relay + //Expect a new message sent with this producer to use the link to the anonymous relay matched above MessageHeaderSectionMatcher headersMatcher = new MessageHeaderSectionMatcher(true); MessageAnnotationsSectionMatcher msgAnnotationsMatcher = new MessageAnnotationsSectionMatcher(true); TransferPayloadCompositeMatcher messageMatcher = new TransferPayloadCompositeMatcher(); messageMatcher.setHeadersMatcher(headersMatcher); messageMatcher.setMessageAnnotationsMatcher(msgAnnotationsMatcher); + testPeer.expectTransfer(messageMatcher); Message message = session.createMessage(); producer.send(dest, message); + //Repeat the send and observe another transfer on the existing link. + testPeer.expectTransfer(messageMatcher); + + producer.send(dest, message); + testPeer.waitForAllHandlersToComplete(1000); } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
