diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java index 1dc21bc28e..97a620acdd 100644 --- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java +++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java @@ -516,6 +516,10 @@ class AmqpProtocolConverter { message.setMessageId(new MessageId(producerId, messageIdGenerator.getNextSequenceId())); } + if (LOG.isTraceEnabled()) { + LOG.trace("Inbound Message:{} from Producer:{}", message.getMessageId(), producerId); + } + DeliveryState remoteState = delivery.getRemoteState(); if (remoteState != null && remoteState instanceof TransactionalState) { TransactionalState s = (TransactionalState) remoteState;