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

Rename Stomp.Headers.Message.PRORITY to .PRIORITY

This commit is contained in:
Ville Skyttä 2016-01-27 19:07:24 +02:00 committed by Clebert Suconic
parent f90a867e21
commit bdea213e88
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/Stomp.java
View File

@ -112,7 +112,7 @@ public interface Stomp {
String REPLY_TO = "reply-to"; String REPLY_TO = "reply-to";
String PRORITY = "priority"; String PRIORITY = "priority";
String REDELIVERED = "redelivered"; String REDELIVERED = "redelivered";

2
artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompUtils.java
View File

@ -91,7 +91,7 @@ public class StompUtils {
} }
command.addHeader(Stomp.Headers.Message.EXPIRATION_TIME, "" + message.getExpiration()); command.addHeader(Stomp.Headers.Message.EXPIRATION_TIME, "" + message.getExpiration());
command.addHeader(Stomp.Headers.Message.REDELIVERED, String.valueOf(deliveryCount > 1)); command.addHeader(Stomp.Headers.Message.REDELIVERED, String.valueOf(deliveryCount > 1));
command.addHeader(Stomp.Headers.Message.PRORITY, "" + message.getPriority()); command.addHeader(Stomp.Headers.Message.PRIORITY, "" + message.getPriority());
if (message.getStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME) != null) { if (message.getStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME) != null) {
command.addHeader(Stomp.Headers.Message.REPLY_TO, message.getStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME)); command.addHeader(Stomp.Headers.Message.REPLY_TO, message.getStringProperty(ClientMessageImpl.REPLYTO_HEADER_NAME));
} }