diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/message/JMSMappingOutboundTransformer.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/message/JMSMappingOutboundTransformer.java index 9ee0344899..efa1a8133b 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/message/JMSMappingOutboundTransformer.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/converter/message/JMSMappingOutboundTransformer.java @@ -177,7 +177,7 @@ public class JMSMappingOutboundTransformer extends OutboundTransformer { } properties.setTo(toAddress(destination)); if (maMap == null) { - maMap = new HashMap(); + maMap = new HashMap<>(); } maMap.put(JMS_DEST_TYPE_MSG_ANNOTATION, destinationType(destination)); } @@ -188,7 +188,7 @@ public class JMSMappingOutboundTransformer extends OutboundTransformer { } properties.setReplyTo(toAddress(replyTo)); if (maMap == null) { - maMap = new HashMap(); + maMap = new HashMap<>(); } maMap.put(JMS_REPLY_TO_TYPE_MSG_ANNOTATION, destinationType(replyTo)); } @@ -293,14 +293,14 @@ public class JMSMappingOutboundTransformer extends OutboundTransformer { continue; } else if (key.startsWith(JMS_AMQP_DELIVERY_ANNOTATION_PREFIX)) { if (daMap == null) { - daMap = new HashMap(); + daMap = new HashMap<>(); } String name = key.substring(JMS_AMQP_DELIVERY_ANNOTATION_PREFIX.length()); daMap.put(Symbol.valueOf(name), message.getObjectProperty(key)); continue; } else if (key.startsWith(JMS_AMQP_MESSAGE_ANNOTATION_PREFIX)) { if (maMap == null) { - maMap = new HashMap(); + maMap = new HashMap<>(); } String name = key.substring(JMS_AMQP_MESSAGE_ANNOTATION_PREFIX.length()); maMap.put(Symbol.valueOf(name), message.getObjectProperty(key)); @@ -325,7 +325,7 @@ public class JMSMappingOutboundTransformer extends OutboundTransformer { continue; } else if (key.startsWith(JMS_AMQP_FOOTER_PREFIX)) { if (footerMap == null) { - footerMap = new HashMap(); + footerMap = new HashMap<>(); } String name = key.substring(JMS_AMQP_FOOTER_PREFIX.length()); footerMap.put(name, message.getObjectProperty(key)); @@ -350,7 +350,7 @@ public class JMSMappingOutboundTransformer extends OutboundTransformer { } if (apMap == null) { - apMap = new HashMap(); + apMap = new HashMap<>(); } Object objectProperty = message.getObjectProperty(key);