lingwei.kong/hawkbit
1
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Fixed problem where correlation data is null.

Browse Source 
Signed-off-by: kaizimmerm <kai.zimmermann@bosch-si.com>
This commit is contained in:
kaizimmerm
2016-06-15 11:25:46 +02:00
parent d0629c8071
commit f04c3655ed
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
hawkbit-dmf-amqp/src/main/java/org/eclipse/hawkbit/amqp/AmqpConfiguration.java
View File

@@ -135,12 +135,10 @@ public class AmqpConfiguration {
rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> { rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
if (ack) { if (ack) {
LOGGER.debug("Message with correlation ID {} confirmed by broker.", correlationData.getId()); LOGGER.debug("Message with {} confirmed by broker.", correlationData);
} else { } else {
LOGGER.error("Broker is unable to handle message with correlation ID {} : {}", correlationData.getId(), LOGGER.error("Broker is unable to handle message with {} : {}", correlationData, cause);
cause);
} }
}); });
return rabbitTemplate; return rabbitTemplate;