diff --git a/hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpConfiguration.java b/hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpConfiguration.java index dcf7e9e99..e40d9bd3c 100644 --- a/hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpConfiguration.java +++ b/hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpConfiguration.java @@ -135,12 +135,10 @@ public class AmqpConfiguration { rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> { if (ack) { - LOGGER.debug("Message with correlation ID {} confirmed by broker.", correlationData.getId()); + LOGGER.debug("Message with {} confirmed by broker.", correlationData); } else { - LOGGER.error("Broker is unable to handle message with correlation ID {} : {}", correlationData.getId(), - cause); + LOGGER.error("Broker is unable to handle message with {} : {}", correlationData, cause); } - }); return rabbitTemplate;