[hornetq-commits] JBoss hornetq SVN: r11414 - in branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp: v11 and 1 other directory.

Author: gaohoward Date: 2011-09-26 01:32:50 -0400 (Mon, 26 Sep 2011) New Revision: 11414 Modified: branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/util/StompClientConnectionV10.java branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/util/StompFrameFactoryV10.java branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/v11/StompTestV11.java Log: test Modified: branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/util/StompClientConnectionV10.java =================================================================== --- branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/util/StompClientConnectionV10.java 2011-09-26 05:11:45 UTC (rev 11413) +++ branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/util/StompClientConnectionV10.java 2011-09-26 05:32:50 UTC (rev 11414) @@ -82,8 +82,7 @@ public ClientStompFrame createFrame( String command) { - // TODO Auto-generated method stub - return null; + return new ClientStompFrameV10(command); } @Override Modified: branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/util/StompFrameFactoryV10.java =================================================================== --- branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/util/StompFrameFactoryV10.java 2011-09-26 05:11:45 UTC (rev 11413) +++ branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/util/StompFrameFactoryV10.java 2011-09-26 05:32:50 UTC (rev 11414) @@ -39,8 +39,6 @@ public ClientStompFrame createFrame(String data) { - System.out.println("Raw data is: " + data + "|"); - //split the string at "\n\n" String[] dataFields = data.split("\n\n"); Modified: branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/v11/StompTestV11.java =================================================================== --- branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/v11/StompTestV11.java 2011-09-26 05:11:45 UTC (rev 11413) +++ branches/STOMP11/tests/integration-tests/src/test/java/org/hornetq/tests/integration/stomp/v11/StompTestV11.java 2011-09-26 05:32:50 UTC (rev 11414) @@ -978,8 +978,33 @@ connV11.disconnect(); newConn.disconnect(); } + + public void testSendAndReceiveOnDifferentConnections() throws Exception + { + connV11.connect(defUser, defPass); + + ClientStompFrame sendFrame = connV11.createFrame("SEND"); + sendFrame.addHeader("destination", getQueuePrefix() + getQueueName()); + sendFrame.setBody("Hello World"); - //tests below are adapted from StompTest + connV11.sendFrame(sendFrame); + + StompClientConnection connV11_2 = StompClientConnectionFactory.createClientConnection("1.1", hostname, port); + connV11_2.connect(defUser, defPass); + + this.subscribe(connV11_2, "sub1", "auto"); + + ClientStompFrame frame = connV11_2.receiveFrame(2000); + + assertEquals("MESSAGE", frame.getCommand()); + assertEquals("Hello World", frame.getBody()); + + connV11.disconnect(); + connV11_2.disconnect(); + } + + //----------------Note: tests below are adapted from StompTest + public void testBeginSameTransactionTwice() throws Exception { connV11.connect(defUser, defPass);