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) {