[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.

[do-not-reply at jboss.org]

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);