|
|
|
@ -70,8 +70,8 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
try { |
|
|
|
try { |
|
|
|
jmsMessage.setJMSCorrelationID((String) jmsCorrelationId); |
|
|
|
jmsMessage.setJMSCorrelationID((String) jmsCorrelationId); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception e) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to set JMSCorrelationID, skipping", e); |
|
|
|
logger.info("Failed to set JMSCorrelationID - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
Destination jmsReplyTo = getHeaderIfAvailable(headers, JmsHeaders.REPLY_TO, Destination.class); |
|
|
|
Destination jmsReplyTo = getHeaderIfAvailable(headers, JmsHeaders.REPLY_TO, Destination.class); |
|
|
|
@ -79,8 +79,8 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
try { |
|
|
|
try { |
|
|
|
jmsMessage.setJMSReplyTo(jmsReplyTo); |
|
|
|
jmsMessage.setJMSReplyTo(jmsReplyTo); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception e) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to set JMSReplyTo, skipping", e); |
|
|
|
logger.info("Failed to set JMSReplyTo - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
String jmsType = getHeaderIfAvailable(headers, JmsHeaders.TYPE, String.class); |
|
|
|
String jmsType = getHeaderIfAvailable(headers, JmsHeaders.TYPE, String.class); |
|
|
|
@ -88,8 +88,8 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
try { |
|
|
|
try { |
|
|
|
jmsMessage.setJMSType(jmsType); |
|
|
|
jmsMessage.setJMSType(jmsType); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception e) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to set JMSType, skipping", e); |
|
|
|
logger.info("Failed to set JMSType - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
Set<String> headerNames = headers.keySet(); |
|
|
|
Set<String> headerNames = headers.keySet(); |
|
|
|
@ -101,14 +101,15 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
String propertyName = this.fromHeaderName(headerName); |
|
|
|
String propertyName = this.fromHeaderName(headerName); |
|
|
|
jmsMessage.setObjectProperty(propertyName, value); |
|
|
|
jmsMessage.setObjectProperty(propertyName, value); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception e) { |
|
|
|
catch (Exception ex) { |
|
|
|
if (headerName.startsWith("JMSX")) { |
|
|
|
if (headerName.startsWith("JMSX")) { |
|
|
|
if (logger.isTraceEnabled()) { |
|
|
|
if (logger.isTraceEnabled()) { |
|
|
|
logger.trace("skipping reserved header, it cannot be set by client: " + headerName); |
|
|
|
logger.trace("Skipping reserved header '" + headerName + |
|
|
|
|
|
|
|
"' since it cannot be set by client"); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
else if (logger.isWarnEnabled()) { |
|
|
|
else if (logger.isWarnEnabled()) { |
|
|
|
logger.warn("failed to map Message header '" + headerName + "' to JMS property", e); |
|
|
|
logger.warn("Failed to map message header '" + headerName + "' to JMS property", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
@ -117,7 +118,7 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
if (logger.isWarnEnabled()) { |
|
|
|
if (logger.isWarnEnabled()) { |
|
|
|
logger.warn("error occurred while mapping from MessageHeaders to JMS properties", ex); |
|
|
|
logger.warn("Error occurred while mapping from MessageHeaders to JMS properties", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
@ -133,7 +134,7 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSCorrelationID property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSCorrelationID property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
try { |
|
|
|
try { |
|
|
|
Destination destination = jmsMessage.getJMSDestination(); |
|
|
|
Destination destination = jmsMessage.getJMSDestination(); |
|
|
|
@ -142,21 +143,21 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSDestination property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSDestination property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
try { |
|
|
|
try { |
|
|
|
int deliveryMode = jmsMessage.getJMSDeliveryMode(); |
|
|
|
int deliveryMode = jmsMessage.getJMSDeliveryMode(); |
|
|
|
headers.put(JmsHeaders.DELIVERY_MODE, deliveryMode); |
|
|
|
headers.put(JmsHeaders.DELIVERY_MODE, deliveryMode); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSDeliveryMode property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSDeliveryMode property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
try { |
|
|
|
try { |
|
|
|
long expiration = jmsMessage.getJMSExpiration(); |
|
|
|
long expiration = jmsMessage.getJMSExpiration(); |
|
|
|
headers.put(JmsHeaders.EXPIRATION, expiration); |
|
|
|
headers.put(JmsHeaders.EXPIRATION, expiration); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSExpiration property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSExpiration property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
try { |
|
|
|
try { |
|
|
|
String messageId = jmsMessage.getJMSMessageID(); |
|
|
|
String messageId = jmsMessage.getJMSMessageID(); |
|
|
|
@ -165,13 +166,13 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSMessageID property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSMessageID property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
try { |
|
|
|
try { |
|
|
|
headers.put(JmsHeaders.PRIORITY, jmsMessage.getJMSPriority()); |
|
|
|
headers.put(JmsHeaders.PRIORITY, jmsMessage.getJMSPriority()); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSPriority property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSPriority property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
try { |
|
|
|
try { |
|
|
|
Destination replyTo = jmsMessage.getJMSReplyTo(); |
|
|
|
Destination replyTo = jmsMessage.getJMSReplyTo(); |
|
|
|
@ -180,13 +181,13 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSReplyTo property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSReplyTo property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
try { |
|
|
|
try { |
|
|
|
headers.put(JmsHeaders.REDELIVERED, jmsMessage.getJMSRedelivered()); |
|
|
|
headers.put(JmsHeaders.REDELIVERED, jmsMessage.getJMSRedelivered()); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSRedelivered property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSRedelivered property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
try { |
|
|
|
try { |
|
|
|
String type = jmsMessage.getJMSType(); |
|
|
|
String type = jmsMessage.getJMSType(); |
|
|
|
@ -195,13 +196,13 @@ public class SimpleJmsHeaderMapper extends AbstractHeaderMapper<Message> impleme |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSType property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSType property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
try { |
|
|
|
try { |
|
|
|
headers.put(JmsHeaders.TIMESTAMP, jmsMessage.getJMSTimestamp()); |
|
|
|
headers.put(JmsHeaders.TIMESTAMP, jmsMessage.getJMSTimestamp()); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) { |
|
|
|
catch (Exception ex) { |
|
|
|
logger.info("failed to read JMSTimestamp property, skipping", ex); |
|
|
|
logger.info("Failed to read JMSTimestamp property - skipping", ex); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|