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

This closes #2502

This commit is contained in:
Michael Andre Pearce 2019-01-18 00:25:39 +00:00
parent 7337274338 300ba4ecda
commit a26608d34a
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/CoreAmqpConverter.java
View File

@ -283,11 +283,11 @@ public class CoreAmqpConverter {
footerMap.put(name, message.getObjectProperty(key));
continue;
}
} else if (key.equals(Message.HDR_GROUP_ID)) {
} else if (key.equals(Message.HDR_GROUP_ID.toString())) {
String value = message.getStringProperty(key);
properties.setGroupId(value);
continue;
} else if (key.equals(Message.HDR_GROUP_SEQUENCE)) {
} else if (key.equals(Message.HDR_GROUP_SEQUENCE.toString())) {
int value = message.getIntProperty(key);
properties.setGroupSequence(UnsignedInteger.valueOf(value));
continue;