Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #2764

This commit is contained in:
Clebert Suconic 2019-07-23 15:01:22 -04:00
parent a08b2d5cdf 6ece896aee
commit fa000524e1
1 changed files with 36 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/stomp/v11/StompV11Test.java
View File

@ -100,44 +100,57 @@ public class StompV11Test extends StompTestBase {
server.getSecurityStore().setSecurityEnabled(true); server.getSecurityStore().setSecurityEnabled(true);
StompClientConnection connection = StompClientConnectionFactory.createClientConnection(v10Uri); StompClientConnection connection = StompClientConnectionFactory.createClientConnection(v10Uri);
connection.connect(defUser, defPass); try {
assertTrue(connection.isConnected()); connection.connect(defUser, defPass);
assertEquals("1.0", connection.getVersion()); assertTrue(connection.isConnected());
connection.disconnect(); assertEquals("1.0", connection.getVersion());
connection = StompClientConnectionFactory.createClientConnection(uri); connection.disconnect();
connection.connect(defUser, defPass); connection.closeTransport();
assertTrue(connection.isConnected()); connection = StompClientConnectionFactory.createClientConnection(uri);
assertEquals("1.1", connection.getVersion()); connection.connect(defUser, defPass);
connection.disconnect(); assertTrue(connection.isConnected());
connection = StompClientConnectionFactory.createClientConnection(uri); assertEquals("1.1", connection.getVersion());
connection.connect(); connection.disconnect();
assertFalse(connection.isConnected()); connection.closeTransport();
//new way of connection connection = StompClientConnectionFactory.createClientConnection(uri);
StompClientConnectionV11 conn = (StompClientConnectionV11) StompClientConnectionFactory.createClientConnection(uri);
conn.connect1(defUser, defPass);
assertTrue(conn.isConnected()); connection.connect();
conn.disconnect(); assertFalse(connection.isConnected());
//invalid user //new way of connection
conn = (StompClientConnectionV11) StompClientConnectionFactory.createClientConnection(uri); StompClientConnectionV11 conn = (StompClientConnectionV11) StompClientConnectionFactory.createClientConnection(uri);
ClientStompFrame frame = conn.connect("invaliduser", defPass); conn.connect1(defUser, defPass);
assertFalse(conn.isConnected());
assertTrue(Stomp.Responses.ERROR.equals(frame.getCommand())); assertTrue(conn.isConnected());
assertTrue(frame.getBody().contains("Security Error occurred"));
conn.disconnect();
conn.closeTransport();
//invalid user
conn = (StompClientConnectionV11) StompClientConnectionFactory.createClientConnection(uri);
ClientStompFrame frame = conn.connect("invaliduser", defPass);
assertFalse(conn.isConnected());
assertTrue(Stomp.Responses.ERROR.equals(frame.getCommand()));
assertTrue(frame.getBody().contains("Security Error occurred"));
conn.closeTransport();
} finally {
connection.closeTransport();
}
} }
@Test @Test