NO-JIRA Adding log.warn on AMQPMessage

apache · Aug 9, 2019 · f303cd7 · f303cd7
1 parent 3ed455c
commit f303cd7
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java b/...-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPMessage.java
@@ -71,10 +71,13 @@
 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 ICoreMessage toCore(CoreMessageObjectPools coreMessageObjectPools) {
          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);
       }
    }