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 #2424

This commit is contained in:
Clebert Suconic 2018-11-14 09:54:29 -05:00
parent 54e9d67b9a 14451a79eb
commit a20d7a0339
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 @Override
public int getGroupSequence() { public int getGroupSequence() {
final Integer integer = this.getIntProperty(Message.HDR_GROUP_SEQUENCE); return containsProperty(Message.HDR_GROUP_SEQUENCE) ? getIntProperty(Message.HDR_GROUP_SEQUENCE) : 0;
return integer == null ? 0 : integer;
} }
/** /**

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 @Override
public final int getIntProperty(String name) throws JMSException { 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 @Override