You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2012/07/05 22:32:22 UTC
svn commit: r1357886 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp: StompLoadTest.java StompTest.java

Author: tabish
Date: Thu Jul  5 20:32:21 2012
New Revision: 1357886

URL: http://svn.apache.org/viewvc?rev=1357886&view=rev
Log:
Clean up the tests so that they send better formated stomp send frames without spaces in the message headers

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompLoadTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompLoadTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompLoadTest.java?rev=1357886&r1=1357885&r2=1357886&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompLoadTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompLoadTest.java Thu Jul  5 20:32:21 2012
@@ -180,7 +180,8 @@ public class StompLoadTest {
         TimeUnit.SECONDS.sleep(5);
 
         for( int ix = 0; ix < MSG_COUNT; ix++) {
-            frame = "SEND\n destination:/topic/" + getDestinationName() +
+            frame = "SEND\n" +
+                    "destination:/topic/" + getDestinationName() +
                     "\nid:" + ix +
                     "\ncontent-length:5" + " \n\n" +
                     "\u0001\u0002\u0000\u0004\u0005" + Stomp.NULL;

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java?rev=1357886&r1=1357885&r2=1357886&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/StompTest.java Thu Jul  5 20:32:21 2012
@@ -490,7 +490,7 @@ public class StompTest extends Combinati
         frame = stompConnection.receiveFrame();
         assertTrue(frame.startsWith("CONNECTED"));
 
-        frame = "SEND\n destination:/queue/" + getQueueName() + "\ncontent-length:5" + " \n\n" + "\u0001\u0002\u0000\u0004\u0005" + Stomp.NULL;
+        frame = "SEND\n" + "destination:/queue/" + getQueueName() + "\ncontent-length:5" + " \n\n" + "\u0001\u0002\u0000\u0004\u0005" + Stomp.NULL;
         stompConnection.sendFrame(frame);
 
         frame = "SUBSCRIBE\n" + "destination:/queue/" + getQueueName() + "\n" + "ack:auto\n\n" + Stomp.NULL;
@@ -519,7 +519,7 @@ public class StompTest extends Combinati
         assertTrue(frame.startsWith("CONNECTED"));
 
         for( int ix = 0; ix < MSG_COUNT; ix++) {
-            frame = "SEND\n destination:/queue/" + getQueueName() + "\ncontent-length:5" + " \n\n" + "\u0001\u0002\u0000\u0004\u0005" + Stomp.NULL;
+            frame = "SEND\n" + "destination:/queue/" + getQueueName() + "\ncontent-length:5" + " \n\n" + "\u0001\u0002\u0000\u0004\u0005" + Stomp.NULL;
             stompConnection.sendFrame(frame);
         }
 
@@ -1821,7 +1821,7 @@ public class StompTest extends Combinati
         assertTrue(receipt.getAction().startsWith("RECEIPT"));
         assertEquals("8fee4b8-4e5c9f66-4703-e936-2", receipt.getHeaders().get("receipt-id"));
 
-        frame = "SEND\n destination:/queue/" + getQueueName() + 123 + "\ncontent-length:0" + " \n\n" + Stomp.NULL;
+        frame = "SEND\n" + "destination:/queue/" + getQueueName() + 123 + "\ncontent-length:0" + " \n\n" + Stomp.NULL;
         stompConnection.sendFrame(frame);
 
         frame = "SUBSCRIBE\n" + "destination:/queue/" + getQueueName() + 123 + "\n" + "id:8fee4b8-4e5c9f66-4703-e936-2" + "\n" + "receipt:8fee4b8-4e5c9f66-4703-e936-1" + "\n\n" + Stomp.NULL;