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

Merge pull request #212 from bsinno/fix_correlationdata_can_be_null

Browse Source 
Fixed problem where correlation data is null.
This commit is contained in:
Kai Zimmermann
2016-06-15 11:35:12 +02:00
committed by GitHub
parent d0629c8071 f04c3655ed
commit 8946d15958
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;