From 62b2f7fe538383c7ff286005e22cbb94ac4df5ee Mon Sep 17 00:00:00 2001 From: "Hiram R. Chirino" Date: Tue, 27 Dec 2005 16:49:20 +0000 Subject: [PATCH] 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 --- .../src/main/java/org/activemq/transport/stomp/Send.java | 4 ++-- .../src/main/java/org/activemq/transport/stomp/Stomp.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/activemq-core/src/main/java/org/activemq/transport/stomp/Send.java b/activemq-core/src/main/java/org/activemq/transport/stomp/Send.java index dc67cef0b7..f7c4f691de 100644 --- a/activemq-core/src/main/java/org/activemq/transport/stomp/Send.java +++ b/activemq-core/src/main/java/org/activemq/transport/stomp/Send.java @@ -96,9 +96,9 @@ class Send implements StompCommand { 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))); diff --git a/activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java b/activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java index bef06cb651..444b30600c 100644 --- a/activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java +++ b/activemq-core/src/main/java/org/activemq/transport/stomp/Stomp.java @@ -58,7 +58,7 @@ public interface Stomp { String CORRELATION_ID = "correlation-id"; String REPLY_TO = "reply-to"; String EXPIRATION_TIME = "expires"; - String PRORITY = "priority"; + String PRIORITY = "priority"; String TYPE = "type"; }