diff --git a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/RefreshListener.java b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/RefreshListener.java index 8b57292..502b494 100644 --- a/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/RefreshListener.java +++ b/spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/RefreshListener.java @@ -56,13 +56,13 @@ public class RefreshListener // TODO Remove this in 3.0.x if (serviceMatcher == null) { log.warn( - "RefreshListener does not have a ServiceMatcher, refresh will not be performed. Consider" - + "passing a ServiceMatcher in the constructor"); - return; + "RefreshListener does not have a ServiceMatcher, refresh may be performed even if " + + "the event does not target this app. Consider passing a ServiceMatcher in " + + "the constructor"); + refresh(); } - if (serviceMatcher.isForSelf(event)) { - Set keys = this.contextRefresher.refresh(); - log.info("Keys refreshed " + keys); + else if (serviceMatcher.isForSelf(event)) { + refresh(); } else { log.info("Refresh not performed, the event was targetting " @@ -70,4 +70,9 @@ public class RefreshListener } } + private void refresh() { + Set keys = this.contextRefresher.refresh(); + log.info("Keys refreshed " + keys); + } + }