Repository: qpid-jms
Updated Branches:
  refs/heads/master 6bd44c040 -> 5c21506fc


QPIDJMS-63: restore checks for expected initial response value


Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/5c21506f
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/5c21506f
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/5c21506f

Branch: refs/heads/master
Commit: 5c21506fcf3ccda968407bba63599219fe4ff40c
Parents: 6bd44c0
Author: Robert Gemmell <[email protected]>
Authored: Tue Jun 2 10:09:06 2015 +0100
Committer: Robert Gemmell <[email protected]>
Committed: Tue Jun 2 10:09:06 2015 +0100

----------------------------------------------------------------------
 .../test/java/org/apache/qpid/jms/test/testpeer/TestAmqpPeer.java  | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/5c21506f/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 079fbb3..186f4b3 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
@@ -379,6 +379,7 @@ public class TestAmqpPeer implements AutoCloseable
 
         addHandler(new SaslInitMatcher()
             .withMechanism(equalTo(Symbol.valueOf("ANONYMOUS")))
+            .withInitialResponse(equalTo(new Binary(new byte[0])))
             .onSuccess(new AmqpPeerRunnable()
             {
                 @Override
@@ -527,6 +528,7 @@ public class TestAmqpPeer implements AutoCloseable
 
         addHandler(new SaslInitMatcher()
             .withMechanism(equalTo(Symbol.valueOf("ANONYMOUS")))
+            .withInitialResponse(equalTo(new Binary(new byte[0])))
             .onSuccess(new AmqpPeerRunnable()
             {
                 @Override


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to