[hornetq-commits] JBoss hornetq SVN: r8917 - in trunk: tests/src/org/hornetq/tests/integration/stomp and 1 other directory.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-03-08 05:02:39 -0500 (Mon, 08 Mar 2010)
New Revision: 8917

Modified:
   trunk/src/main/org/hornetq/core/protocol/stomp/Stomp.java
   trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java
   trunk/tests/src/org/hornetq/tests/integration/stomp/StompTest.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-129: Implement STOMP v1.0

* fix typo for Subscribe's durable-subscriber-name header

Modified: trunk/src/main/org/hornetq/core/protocol/stomp/Stomp.java
===================================================================
--- trunk/src/main/org/hornetq/core/protocol/stomp/Stomp.java	2010-03-08 09:49:01 UTC (rev 8916)
+++ trunk/src/main/org/hornetq/core/protocol/stomp/Stomp.java	2010-03-08 10:02:39 UTC (rev 8917)
@@ -131,7 +131,7 @@
 
          String SELECTOR = "selector";
 
-         String DURABLE_SUBSCRIPTION_NAME = "durable-subscription-name";
+         String DURABLE_SUBSCRIBER_NAME = "durable-subscriber-name";
 
          String NO_LOCAL = "no-local";
 

Modified: trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java
===================================================================
--- trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java	2010-03-08 09:49:01 UTC (rev 8916)
+++ trunk/src/main/org/hornetq/core/protocol/stomp/StompProtocolManager.java	2010-03-08 10:02:39 UTC (rev 8917)
@@ -257,7 +257,7 @@
       String selector = (String)headers.get(Stomp.Headers.Subscribe.SELECTOR);
       String ack = (String)headers.get(Stomp.Headers.Subscribe.ACK_MODE);
       String id = (String)headers.get(Stomp.Headers.Subscribe.ID);
-      String durableSubscriptionName = (String)headers.get(Stomp.Headers.Subscribe.DURABLE_SUBSCRIPTION_NAME);
+      String durableSubscriptionName = (String)headers.get(Stomp.Headers.Subscribe.DURABLE_SUBSCRIBER_NAME);
       boolean noLocal = false;
       if (headers.containsKey(Stomp.Headers.Subscribe.NO_LOCAL))
       {

Modified: trunk/tests/src/org/hornetq/tests/integration/stomp/StompTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/stomp/StompTest.java	2010-03-08 09:49:01 UTC (rev 8916)
+++ trunk/tests/src/org/hornetq/tests/integration/stomp/StompTest.java	2010-03-08 10:02:39 UTC (rev 8917)
@@ -1235,7 +1235,7 @@
        String subscribeFrame =
                "SUBSCRIBE\n" +
                        "destination:" + getTopicPrefix() + getTopicName() + "\n" +
-                       "durable-subscription-name: " + getName() + "\n" + 
+                       "durable-subscriber-name: " + getName() + "\n" + 
                        "\n\n" +
                        Stomp.NULL;
        sendFrame(subscribeFrame);
@@ -1295,7 +1295,7 @@
                "SUBSCRIBE\n" +
                        "destination:" + getTopicPrefix() + getTopicName() + "\n" +
                        "receipt: 12\n" +
-                       "durable-subscription-name: " + getName() + "\n" + 
+                       "durable-subscriber-name: " + getName() + "\n" + 
                        "\n\n" +
                        Stomp.NULL;
        sendFrame(subscribeFrame);