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

ARTEMIS-2142 Patch Fix ServerJMSMessage for JMSXGROUPSEQ 

This is a patch fix for JMSXGROUPSEQ.
This commit is contained in:
Michael André Pearce 2018-11-09 14:57:20 +00:00 committed by Clebert Suconic
parent 54e9d67b9a
commit 14451a79eb
2 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
artemis-core-client/src/main/java/org/apache/activemq/artemis/core/message/impl/CoreMessage.java
View File

@ -291,8 +291,7 @@ public class CoreMessage extends RefCountMessage implements ICoreMessage {
@Override
public int getGroupSequence() {
final Integer integer = this.getIntProperty(Message.HDR_GROUP_SEQUENCE);
return integer == null ? 0 : integer;
return containsProperty(Message.HDR_GROUP_SEQUENCE) ? getIntProperty(Message.HDR_GROUP_SEQUENCE) : 0;
}
/**

6
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/jms/ServerJMSMessage.java
View File

@ -266,7 +266,11 @@ public class ServerJMSMessage implements Message {
@Override
public final int getIntProperty(String name) throws JMSException {
return message.getIntProperty(name);
if (MessageUtil.JMSXGROUPSEQ.equals(name)) {
return message.getGroupSequence();
} else {
return message.getIntProperty(name);
}
}
@Override