From f303cd7ca92bcc8f4adfdbaf7cbaf4e6107ab312 Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Fri, 9 Aug 2019 14:05:41 -0400 Subject: [PATCH] NO-JIRA Adding log.warn on AMQPMessage --- .../activemq/artemis/protocol/amqp/broker/AMQPMessage.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java index df35115dd9..540d27714e 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java @@ -71,10 +71,13 @@ import org.apache.qpid.proton.message.impl.MessageImpl; import io.netty.buffer.ByteBuf; import io.netty.buffer.PooledByteBufAllocator; import io.netty.buffer.Unpooled; +import org.jboss.logging.Logger; // see https://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#section-message-format public class AMQPMessage extends RefCountMessage { + private static final Logger logger = Logger.getLogger(AMQPMessage.class); + public static final SimpleString ADDRESS_PROPERTY = SimpleString.toSimpleString("_AMQ_AD"); public static final int DEFAULT_MESSAGE_FORMAT = 0; @@ -692,6 +695,7 @@ public class AMQPMessage extends RefCountMessage { return AmqpCoreConverter.toCore( this, coreMessageObjectPools, header, messageAnnotations, properties, lazyDecodeApplicationProperties(), getBody(), getFooter()); } catch (Exception e) { + logger.warn(e.getMessage(), e); throw new RuntimeException(e.getMessage(), e); } }