[activemq-artemis] branch master updated: NO-JIRA Adding log.warn on AMQPMessage

[cl...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

clebertsuconic pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git


The following commit(s) were added to refs/heads/master by this push:
     new f303cd7  NO-JIRA Adding log.warn on AMQPMessage
f303cd7 is described below

commit f303cd7ca92bcc8f4adfdbaf7cbaf4e6107ab312
Author: Clebert Suconic <cl...@apache.org>
AuthorDate: Fri Aug 9 14:05:41 2019 -0400

    NO-JIRA Adding log.warn on AMQPMessage
---
 .../org/apache/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 df35115..540d277 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);
       }
    }