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"; }