SpringCloud/spring-cloud-bus
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

move from slf4j to commons log, fix package scope fields

Browse Source
This commit is contained in:
Spencer Gibb
2015-01-15 14:41:18 -07:00
parent 6918a9c640
commit 78f435ef29
2 changed files with 7 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/EnvironmentChangeListener.java
View File

@@ -1,7 +1,6 @@
package org.springframework.cloud.bus.event;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import lombok.extern.apachecommons.CommonsLog;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.cloud.context.environment.EnvironmentManager;
@@ -11,16 +10,15 @@ import java.util.Map;
/**
* @author Spencer Gibb
*/
@CommonsLog
public class EnvironmentChangeListener implements ApplicationListener<EnvironmentChangeRemoteApplicationEvent> {
private static final Logger logger = LoggerFactory.getLogger(EnvironmentChangeListener.class);
@Autowired
private EnvironmentManager env;
@Override
public void onApplicationEvent(EnvironmentChangeRemoteApplicationEvent event) {
Map<String, String> values = event.getValues();
logger.info("Received remote environment change request. Keys/values to update {}", values);
log.info("Received remote environment change request. Keys/values to update " + values);
for (Map.Entry<String, String> entry: values.entrySet()) {
env.setProperty(entry.getKey(), entry.getValue());
}

9
spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/RefreshListener.java
View File

@@ -1,7 +1,6 @@
package org.springframework.cloud.bus.event;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import lombok.extern.apachecommons.CommonsLog;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationListener;
import org.springframework.cloud.config.client.RefreshEndpoint;
@@ -11,15 +10,15 @@ import java.util.Arrays;
/**
* @author Spencer Gibb
*/
@CommonsLog
public class RefreshListener implements ApplicationListener<RefreshRemoteApplicationEvent> {
private static final Logger logger = LoggerFactory.getLogger(RefreshListener.class);
@Autowired
RefreshEndpoint endpoint;
private RefreshEndpoint endpoint;
@Override
public void onApplicationEvent(RefreshRemoteApplicationEvent event) {
String[] keys = endpoint.refresh();
logger.info("Received remote refresh request. Keys refreshed {}", Arrays.asList(keys));
log.info("Received remote refresh request. Keys refreshed " + Arrays.asList(keys));
}
}