You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2015/03/02 16:12:26 UTC
[2/2] qpid-jms git commit: add some tests using ANONYMOUS and PLAIN
explicitly
add some tests using ANONYMOUS and PLAIN explicitly
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/7a5b6f3a
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/7a5b6f3a
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/7a5b6f3a
Branch: refs/heads/master
Commit: 7a5b6f3a5cb737eb09352a63edb8bd251da453a1
Parents: e58678f
Author: Robert Gemmell <ro...@apache.org>
Authored: Mon Mar 2 15:11:17 2015 +0000
Committer: Robert Gemmell <ro...@apache.org>
Committed: Mon Mar 2 15:11:17 2015 +0000
----------------------------------------------------------------------
.../jms/integration/SaslIntegrationTest.java | 44 ++++++++++++++++++++
1 file changed, 44 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/7a5b6f3a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SaslIntegrationTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SaslIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SaslIntegrationTest.java
index d655bef..710e128 100644
--- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SaslIntegrationTest.java
+++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/SaslIntegrationTest.java
@@ -53,4 +53,48 @@ public class SaslIntegrationTest extends QpidJmsTestCase {
connection.close();
}
}
+
+ @Test(timeout = 5000)
+ public void testSaslPlainConnection() throws Exception {
+ try (TestAmqpPeer testPeer = new TestAmqpPeer();) {
+
+ // Expect a PLAIN connection
+ testPeer.expectPlainConnect("guest", "guest", null, null);
+ // Each connection creates a session for managing temporary destinations etc
+ testPeer.expectBegin(true);
+
+ ConnectionFactory factory = new JmsConnectionFactory("amqp://localhost:" + testPeer.getServerPort());
+ Connection connection = factory.createConnection("guest", "guest");
+ // Set a clientID to provoke the actual AMQP connection process to occur.
+ connection.setClientID("clientName");
+
+ testPeer.waitForAllHandlersToComplete(1000);
+ assertNull(testPeer.getThrowable());
+
+ testPeer.expectClose();
+ connection.close();
+ }
+ }
+
+ @Test(timeout = 5000)
+ public void testSaslAnonymousConnection() throws Exception {
+ try (TestAmqpPeer testPeer = new TestAmqpPeer();) {
+
+ // Expect an ANOYMOUS connection
+ testPeer.expectAnonymousConnect(true);
+ // Each connection creates a session for managing temporary destinations etc
+ testPeer.expectBegin(true);
+
+ ConnectionFactory factory = new JmsConnectionFactory("amqp://localhost:" + testPeer.getServerPort());
+ Connection connection = factory.createConnection();
+ // Set a clientID to provoke the actual AMQP connection process to occur.
+ connection.setClientID("clientName");
+
+ testPeer.waitForAllHandlersToComplete(1000);
+ assertNull(testPeer.getThrowable());
+
+ testPeer.expectClose();
+ connection.close();
+ }
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org