activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r359240 - in /incubator/activemq/trunk/activemq-core/src/main/java/org/activemq/transport/stomp: Send.java Stomp.java
Date Tue, 27 Dec 2005 16:49:30 GMT
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 sanders@apache.org 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";
         }
 



Mime
View raw message