From f04c3655edc58661f7de61089b55d929de53a5dd Mon Sep 17 00:00:00 2001 From: kaizimmerm Date: Wed, 15 Jun 2016 11:25:46 +0200 Subject: [PATCH] Fixed problem where correlation data is null. Signed-off-by: kaizimmerm --- .../java/org/eclipse/hawkbit/amqp/AmqpConfiguration.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) 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;