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

This commit is contained in:
Clebert Suconic 2016-09-09 09:49:38 -04:00
parent a18ad27841 8c7599d5e4
commit 2ef20e6152
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -32,8 +32,9 @@ import org.apache.activemq.artemis.reader.MessageUtil;
public class ServerJMSMessage implements Message { public class ServerJMSMessage implements Message {
public static final String NATIVE_MESSAGE_ID = "NATIVE_MESSAGE_ID";
protected final MessageInternal message; protected final MessageInternal message;
private final String NATIVE_MESSAGE_ID = "NATIVE_MESSAGE_ID";
protected int deliveryCount; protected int deliveryCount;

3
artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/proton/converter/message/JMSMappingOutboundTransformer.java
View File

@ -17,6 +17,7 @@
package org.apache.activemq.artemis.core.protocol.proton.converter.message; package org.apache.activemq.artemis.core.protocol.proton.converter.message;
import org.apache.activemq.artemis.core.message.impl.MessageInternal; import org.apache.activemq.artemis.core.message.impl.MessageInternal;
import org.apache.activemq.artemis.core.protocol.proton.converter.jms.ServerJMSMessage;
import org.apache.qpid.proton.amqp.Binary; import org.apache.qpid.proton.amqp.Binary;
import org.apache.qpid.proton.amqp.Symbol; import org.apache.qpid.proton.amqp.Symbol;
import org.apache.qpid.proton.amqp.UnsignedByte; import org.apache.qpid.proton.amqp.UnsignedByte;
@ -223,7 +224,7 @@ public class JMSMappingOutboundTransformer extends OutboundTransformer {
final Enumeration<String> keys = msg.getPropertyNames(); final Enumeration<String> keys = msg.getPropertyNames();
while (keys.hasMoreElements()) { while (keys.hasMoreElements()) {
String key = keys.nextElement(); String key = keys.nextElement();
if (key.equals(messageFormatKey) || key.equals(nativeKey)) { if (key.equals(messageFormatKey) || key.equals(nativeKey) || key.equals(ServerJMSMessage.NATIVE_MESSAGE_ID)) {
// skip.. // skip..
} }
else if (key.equals(firstAcquirerKey)) { else if (key.equals(firstAcquirerKey)) {