[
https://issues.apache.org/jira/browse/ARTEMIS-215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justin Bertram resolved ARTEMIS-215.
------------------------------------
Resolution: Not A Problem
> 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
> Priority: Major
>
> 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
(v8.20.10#820010)
