svn commit: r359240 - in /incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp: Send.java Stomp.java

[chirino]

Author: chirino
Date: Tue Dec 27 08:49:20 2005
New Revision: 359240

URL: http://svn.apache.org/viewcvs?rev=359240&view=rev
Log:
Applying patch suggested by [EMAIL PROTECTED] to fix stomp priority bug.

Modified:
    
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Send.java
    
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Send.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Send.java?rev=359240&r1=359239&r2=359240&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Send.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Send.java
 Tue Dec 27 08:49:20 2005
@@ -96,9 +96,9 @@
         if (expiration != null) {
             msg.setJMSExpiration(asLong(expiration));
         }
-        Object priority = headers.remove(Stomp.Headers.Send.PRORITY);
+        Object priority = headers.remove(Stomp.Headers.Send.PRIORITY);
         if (priority != null) {
-            msg.setJMSExpiration(asInt(priority));
+            msg.setJMSPriority(asInt(priority));
         }
 
         msg.setJMSReplyTo(DestinationNamer.convert((String) 
headers.remove(Stomp.Headers.Send.REPLY_TO)));

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java
URL: 
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java?rev=359240&r1=359239&r2=359240&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java
 Tue Dec 27 08:49:20 2005
@@ -58,7 +58,7 @@
             String CORRELATION_ID = "correlation-id";
             String REPLY_TO = "reply-to";
             String EXPIRATION_TIME = "expires";
-            String PRORITY = "priority";
+            String PRIORITY = "priority";
             String TYPE = "type";
         }