You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Martyn Taylor (JIRA)" <ji...@apache.org> on 2017/03/10 13:57:06 UTC
[jira] [Updated] (ARTEMIS-215) OpenWireMessageConverter sets
headers that need reviewed abd removed if not needed
[ https://issues.apache.org/jira/browse/ARTEMIS-215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Martyn Taylor updated ARTEMIS-215:
----------------------------------
Fix Version/s: (was: 2.0.0)
2.next
> OpenWireMessageConverter sets headers that need reviewed abd removed if not needed
> ----------------------------------------------------------------------------------
>
> Key: ARTEMIS-215
> URL: https://issues.apache.org/jira/browse/ARTEMIS-215
> Project: ActiveMQ Artemis
> Issue Type: Sub-task
> Components: OpenWire
> Reporter: Andy Taylor
> Assignee: Andy Taylor
> Fix For: 2.next
>
>
> in the OpenWireMessageConverter there are a number of headers that are set and unset on the ActiveMQMessage. These are either redundant or should be mapped to internal Artemis constructs.
> for instance AMQ_MSG_ORIG_DESTINATION is set in ActiveMQ when messages are routed to the DLQ so this should be mapped to HDR_ORIGINAL_QUEUE on MessageImpl.
> The headers to check are:
> public static final String AMQ_MSG_DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY = AMQ_PREFIX + "dlqDeliveryFailureCause";
> private static final String AMQ_MSG_ARRIVAL = AMQ_PREFIX + "ARRIVAL";
> private static final String AMQ_MSG_BROKER_IN_TIME = AMQ_PREFIX + "BROKER_IN_TIME";
> private static final String AMQ_MSG_BROKER_PATH = AMQ_PREFIX + "BROKER_PATH";
> private static final String AMQ_MSG_CLUSTER = AMQ_PREFIX + "CLUSTER";
> private static final String AMQ_MSG_COMMAND_ID = AMQ_PREFIX + "COMMAND_ID";
> private static final String AMQ_MSG_DATASTRUCTURE = AMQ_PREFIX + "DATASTRUCTURE";
> private static final String AMQ_MSG_GROUP_ID = AMQ_PREFIX + "GROUP_ID";
> private static final String AMQ_MSG_GROUP_SEQUENCE = AMQ_PREFIX + "GROUP_SEQUENCE";
> private static final String AMQ_MSG_MESSAGE_ID = AMQ_PREFIX + "MESSAGE_ID";
> private static final String AMQ_MSG_ORIG_DESTINATION = AMQ_PREFIX + "ORIG_DESTINATION";
> private static final String AMQ_MSG_ORIG_TXID = AMQ_PREFIX + "ORIG_TXID";
> private static final String AMQ_MSG_PRODUCER_ID = AMQ_PREFIX + "PRODUCER_ID";
> private static final String AMQ_MSG_MARSHALL_PROP = AMQ_PREFIX + "MARSHALL_PROP";
> private static final String AMQ_MSG_REDELIVER_COUNTER = AMQ_PREFIX + "REDELIVER_COUNTER";
> private static final String AMQ_MSG_REPLY_TO = AMQ_PREFIX + "REPLY_TO";
> private static final String AMQ_MSG_CONSUMER_ID = AMQ_PREFIX + "CONSUMER_ID";
> private static final String AMQ_MSG_TX_ID = AMQ_PREFIX + "TX_ID";
> private static final String AMQ_MSG_USER_ID = AMQ_PREFIX + "USER_ID";
> private static final String AMQ_MSG_COMPRESSED = AMQ_PREFIX + "COMPRESSED";
> private static final String AMQ_MSG_DROPPABLE = AMQ_PREFIX + "DROPPABLE";
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)