From 230217c41ad111bea528ac2222d8b04d82c6ac30 Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Wed, 27 Aug 2014 14:25:11 -0600 Subject: [PATCH] check if destination is empty, not just null --- .../platform/bus/amqp/AmqpBusAutoConfiguration.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/main/java/org/springframework/platform/bus/amqp/AmqpBusAutoConfiguration.java b/src/main/java/org/springframework/platform/bus/amqp/AmqpBusAutoConfiguration.java index d648de5..ac34e1b 100644 --- a/src/main/java/org/springframework/platform/bus/amqp/AmqpBusAutoConfiguration.java +++ b/src/main/java/org/springframework/platform/bus/amqp/AmqpBusAutoConfiguration.java @@ -100,7 +100,9 @@ public class AmqpBusAutoConfiguration { } private boolean isForSelf(RemoteApplicationEvent event) { - return (event.getDestinationService() == null || event.getDestinationService().equals(getAppName())); + return (event.getDestinationService() == null + || event.getDestinationService().trim().isEmpty() + || event.getDestinationService().equals(getAppName())); } private boolean isFromSelf(RemoteApplicationEvent event) {