Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Applying patch suggested by sanders@apache.org to fix stomp priority bug. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@359240 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2005-12-27 16:49:20 +00:00
parent 5cea195af2
commit 62b2f7fe53
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-core/src/main/java/org/activemq/transport/stomp/Send.java
View File

@ -96,9 +96,9 @@ class Send implements StompCommand {
if (expiration != null) { if (expiration != null) {
msg.setJMSExpiration(asLong(expiration)); msg.setJMSExpiration(asLong(expiration));
} }
Object priority = headers.remove(Stomp.Headers.Send.PRORITY); Object priority = headers.remove(Stomp.Headers.Send.PRIORITY);
if (priority != null) { if (priority != null) {
msg.setJMSExpiration(asInt(priority)); msg.setJMSPriority(asInt(priority));
} }
msg.setJMSReplyTo(DestinationNamer.convert((String) headers.remove(Stomp.Headers.Send.REPLY_TO))); msg.setJMSReplyTo(DestinationNamer.convert((String) headers.remove(Stomp.Headers.Send.REPLY_TO)));

2
activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java
View File

@ -58,7 +58,7 @@ public interface Stomp {
String CORRELATION_ID = "correlation-id"; String CORRELATION_ID = "correlation-id";
String REPLY_TO = "reply-to"; String REPLY_TO = "reply-to";
String EXPIRATION_TIME = "expires"; String EXPIRATION_TIME = "expires";
String PRORITY = "priority"; String PRIORITY = "priority";
String TYPE = "type"; String TYPE = "type";
} }