diff --git a/src/main/java/org/springframework/platform/bus/AbstractBusEndpoint.java b/src/main/java/org/springframework/platform/bus/AbstractBusEndpoint.java index 7bd6778..c3b8c8b 100644 --- a/src/main/java/org/springframework/platform/bus/AbstractBusEndpoint.java +++ b/src/main/java/org/springframework/platform/bus/AbstractBusEndpoint.java @@ -17,6 +17,10 @@ public class AbstractBusEndpoint implements MvcEndpoint { @Autowired private BusEndpoint delegate; + protected String getAppName() { + return env.getProperty("spring.application.name"); + } + @Override public String getPath() { return "/" + this.delegate.getId(); diff --git a/src/main/java/org/springframework/platform/bus/RefreshBusEndpoint.java b/src/main/java/org/springframework/platform/bus/RefreshBusEndpoint.java index 86f0a95..d04cfc4 100644 --- a/src/main/java/org/springframework/platform/bus/RefreshBusEndpoint.java +++ b/src/main/java/org/springframework/platform/bus/RefreshBusEndpoint.java @@ -16,8 +16,8 @@ public class RefreshBusEndpoint extends AbstractBusEndpoint { @RequestMapping(value = "refresh", method = RequestMethod.POST) @ResponseBody public void refresh(@RequestParam Map params) { - context.publishEvent(new RefreshRemoteApplicationEvent(this, env.getProperty("spring.application.name"))); - //return "remote refresh event sent to bus"; + context.publishEvent(new RefreshRemoteApplicationEvent(this, getAppName())); } + }