[ARTEMIS-215] OpenWireMessageConverter sets headers that need reviewed abd removed if not needed

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Not A Problem
• Component/s: OpenWire
• Assignee: Andy Taylor
• Reporter: Andy Taylor
• Created: 27/Aug/15 09:34
• Updated: 10/Apr/24 15:03
• Resolved: 10/Apr/24 15:03

Description

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";