From 3ea113fd156c2fea2a9f8d87376e8b9fb2bfa0ff Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Fri, 22 Aug 2014 14:15:36 -0600 Subject: [PATCH] move getAppName to AbstractBusEndpoint --- .../org/springframework/platform/bus/AbstractBusEndpoint.java | 4 ++++ .../org/springframework/platform/bus/RefreshBusEndpoint.java | 4 ++-- 2 files changed, 6 insertions(+), 2 deletions(-) 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())); } + }