Commit 91f22b50 by Ryan Baxter

Merge remote-tracking branch 'origin/master' into 2.0.x

parents 0a423fc4 0d19a55d
...@@ -28,6 +28,9 @@ ...@@ -28,6 +28,9 @@
<spring-cloud-config.version>2.0.0.BUILD-SNAPSHOT</spring-cloud-config.version> <spring-cloud-config.version>2.0.0.BUILD-SNAPSHOT</spring-cloud-config.version>
<spring-cloud-stream.version>Elmhurst.BUILD-SNAPSHOT</spring-cloud-stream.version> <spring-cloud-stream.version>Elmhurst.BUILD-SNAPSHOT</spring-cloud-stream.version>
<!-- Plugin versions -->
<maven-compiler-plugin.version>3.6.1</maven-compiler-plugin.version>
<maven-eclipse-plugin.version>2.10</maven-eclipse-plugin.version>
<!-- Sonar --> <!-- Sonar -->
<surefire.plugin.version>2.19.1</surefire.plugin.version> <surefire.plugin.version>2.19.1</surefire.plugin.version>
<sonar.java.coveragePlugin>jacoco</sonar.java.coveragePlugin> <sonar.java.coveragePlugin>jacoco</sonar.java.coveragePlugin>
...@@ -40,6 +43,7 @@ ...@@ -40,6 +43,7 @@
<plugin> <plugin>
<groupId>org.apache.maven.plugins</groupId> <groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-eclipse-plugin</artifactId> <artifactId>maven-eclipse-plugin</artifactId>
<version>${maven-eclipse-plugin.version}</version>
<configuration> <configuration>
<useProjectReferences>false</useProjectReferences> <useProjectReferences>false</useProjectReferences>
<additionalConfig> <additionalConfig>
...@@ -56,6 +60,7 @@ ...@@ -56,6 +60,7 @@
</plugin> </plugin>
<plugin> <plugin>
<artifactId>maven-compiler-plugin</artifactId> <artifactId>maven-compiler-plugin</artifactId>
<version>${maven-compiler-plugin.version}</version>
<configuration> <configuration>
<source>1.8</source> <source>1.8</source>
<target>1.8</target> <target>1.8</target>
......
...@@ -39,6 +39,8 @@ import org.apache.commons.configuration.SystemConfiguration; ...@@ -39,6 +39,8 @@ import org.apache.commons.configuration.SystemConfiguration;
import org.apache.commons.configuration.event.ConfigurationEvent; import org.apache.commons.configuration.event.ConfigurationEvent;
import org.apache.commons.configuration.event.ConfigurationListener; import org.apache.commons.configuration.event.ConfigurationListener;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.actuate.condition.ConditionalOnEnabledEndpoint; import org.springframework.boot.actuate.condition.ConditionalOnEnabledEndpoint;
import org.springframework.boot.actuate.endpoint.Endpoint; import org.springframework.boot.actuate.endpoint.Endpoint;
...@@ -62,18 +64,17 @@ import static com.netflix.config.ConfigurationManager.ENV_CONFIG_NAME; ...@@ -62,18 +64,17 @@ import static com.netflix.config.ConfigurationManager.ENV_CONFIG_NAME;
import static com.netflix.config.ConfigurationManager.SYS_CONFIG_NAME; import static com.netflix.config.ConfigurationManager.SYS_CONFIG_NAME;
import static com.netflix.config.ConfigurationManager.URL_CONFIG_NAME; import static com.netflix.config.ConfigurationManager.URL_CONFIG_NAME;
import lombok.extern.apachecommons.CommonsLog;
/** /**
* @author Spencer Gibb * @author Spencer Gibb
*/ */
@Configuration @Configuration
@ConditionalOnClass({ ConcurrentCompositeConfiguration.class, @ConditionalOnClass({ ConcurrentCompositeConfiguration.class,
ConfigurationBuilder.class }) ConfigurationBuilder.class })
@CommonsLog
@AutoConfigureOrder(Ordered.HIGHEST_PRECEDENCE) @AutoConfigureOrder(Ordered.HIGHEST_PRECEDENCE)
public class ArchaiusAutoConfiguration { public class ArchaiusAutoConfiguration {
private static final Log log = LogFactory.getLog(ArchaiusAutoConfiguration.class);
private static final AtomicBoolean initialized = new AtomicBoolean(false); private static final AtomicBoolean initialized = new AtomicBoolean(false);
@Autowired @Autowired
......
...@@ -14,14 +14,12 @@ import org.springframework.util.MultiValueMap; ...@@ -14,14 +14,12 @@ import org.springframework.util.MultiValueMap;
import feign.FeignException; import feign.FeignException;
import feign.Response; import feign.Response;
import feign.codec.Decoder; import feign.codec.Decoder;
import lombok.extern.slf4j.Slf4j;
/** /**
* Decoder adds compatibility for Spring MVC's ResponseEntity to any other decoder via * Decoder adds compatibility for Spring MVC's ResponseEntity to any other decoder via
* composition. * composition.
* @author chadjaros * @author chadjaros
*/ */
@Slf4j
public class ResponseEntityDecoder implements Decoder { public class ResponseEntityDecoder implements Decoder {
private Decoder decoder; private Decoder decoder;
......
...@@ -24,6 +24,8 @@ import java.lang.reflect.Type; ...@@ -24,6 +24,8 @@ import java.lang.reflect.Type;
import java.nio.charset.Charset; import java.nio.charset.Charset;
import java.util.Collection; import java.util.Collection;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.ObjectFactory; import org.springframework.beans.factory.ObjectFactory;
import org.springframework.boot.autoconfigure.http.HttpMessageConverters; import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
import org.springframework.http.HttpHeaders; import org.springframework.http.HttpHeaders;
...@@ -35,7 +37,6 @@ import org.springframework.http.converter.HttpMessageConverter; ...@@ -35,7 +37,6 @@ import org.springframework.http.converter.HttpMessageConverter;
import feign.RequestTemplate; import feign.RequestTemplate;
import feign.codec.EncodeException; import feign.codec.EncodeException;
import feign.codec.Encoder; import feign.codec.Encoder;
import lombok.extern.apachecommons.CommonsLog;
import static org.springframework.cloud.netflix.feign.support.FeignUtils.getHeaders; import static org.springframework.cloud.netflix.feign.support.FeignUtils.getHeaders;
import static org.springframework.cloud.netflix.feign.support.FeignUtils.getHttpHeaders; import static org.springframework.cloud.netflix.feign.support.FeignUtils.getHttpHeaders;
...@@ -43,9 +44,10 @@ import static org.springframework.cloud.netflix.feign.support.FeignUtils.getHttp ...@@ -43,9 +44,10 @@ import static org.springframework.cloud.netflix.feign.support.FeignUtils.getHttp
/** /**
* @author Spencer Gibb * @author Spencer Gibb
*/ */
@CommonsLog
public class SpringEncoder implements Encoder { public class SpringEncoder implements Encoder {
private static final Log log = LogFactory.getLog(SpringEncoder.class);
private ObjectFactory<HttpMessageConverters> messageConverters; private ObjectFactory<HttpMessageConverters> messageConverters;
public SpringEncoder(ObjectFactory<HttpMessageConverters> messageConverters) { public SpringEncoder(ObjectFactory<HttpMessageConverters> messageConverters) {
......
...@@ -19,16 +19,18 @@ import java.util.Map; ...@@ -19,16 +19,18 @@ import java.util.Map;
import com.netflix.servo.MonitorRegistry; import com.netflix.servo.MonitorRegistry;
import com.netflix.servo.monitor.BasicTimer; import com.netflix.servo.monitor.BasicTimer;
import com.netflix.servo.monitor.MonitorConfig; import com.netflix.servo.monitor.MonitorConfig;
import org.apache.commons.logging.Log;
import lombok.extern.apachecommons.CommonsLog; import org.apache.commons.logging.LogFactory;
/** /**
* Servo does not provide a mechanism to retrieve an existing monitor by name + tags. * Servo does not provide a mechanism to retrieve an existing monitor by name + tags.
* *
* @author Jon Schneider * @author Jon Schneider
*/ */
@CommonsLog
public class ServoMonitorCache { public class ServoMonitorCache {
private static final Log log = LogFactory.getLog(ServoMonitorCache.class);
private final Map<MonitorConfig, BasicTimer> timerCache = new HashMap<>(); private final Map<MonitorConfig, BasicTimer> timerCache = new HashMap<>();
private final MonitorRegistry monitorRegistry; private final MonitorRegistry monitorRegistry;
private final ServoMetricsConfigBean config; private final ServoMetricsConfigBean config;
......
...@@ -22,6 +22,8 @@ import java.util.Map; ...@@ -22,6 +22,8 @@ import java.util.Map;
import javax.annotation.PostConstruct; import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy; import javax.annotation.PreDestroy;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.util.ReflectionUtils; import org.springframework.util.ReflectionUtils;
import com.netflix.zuul.FilterLoader; import com.netflix.zuul.FilterLoader;
...@@ -30,17 +32,16 @@ import com.netflix.zuul.filters.FilterRegistry; ...@@ -30,17 +32,16 @@ import com.netflix.zuul.filters.FilterRegistry;
import com.netflix.zuul.monitoring.CounterFactory; import com.netflix.zuul.monitoring.CounterFactory;
import com.netflix.zuul.monitoring.TracerFactory; import com.netflix.zuul.monitoring.TracerFactory;
import lombok.extern.apachecommons.CommonsLog;
/** /**
* Initializes various Zuul components including {@link ZuulFilter}. * Initializes various Zuul components including {@link ZuulFilter}.
* *
* @author Spencer Gibb * @author Spencer Gibb
* *
*/ */
@CommonsLog
public class ZuulFilterInitializer { public class ZuulFilterInitializer {
private static final Log log = LogFactory.getLog(ZuulFilterInitializer.class);
private final Map<String, ZuulFilter> filters; private final Map<String, ZuulFilter> filters;
private final CounterFactory counterFactory; private final CounterFactory counterFactory;
private final TracerFactory tracerFactory; private final TracerFactory tracerFactory;
......
...@@ -31,6 +31,8 @@ import java.util.Set; ...@@ -31,6 +31,8 @@ import java.util.Set;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.cloud.netflix.zuul.util.RequestUtils; import org.springframework.cloud.netflix.zuul.util.RequestUtils;
import org.springframework.http.HttpHeaders; import org.springframework.http.HttpHeaders;
import org.springframework.util.LinkedMultiValueMap; import org.springframework.util.LinkedMultiValueMap;
...@@ -46,16 +48,15 @@ import static org.springframework.cloud.netflix.zuul.filters.support.FilterConst ...@@ -46,16 +48,15 @@ import static org.springframework.cloud.netflix.zuul.filters.support.FilterConst
import static org.springframework.http.HttpHeaders.CONTENT_ENCODING; import static org.springframework.http.HttpHeaders.CONTENT_ENCODING;
import static org.springframework.http.HttpHeaders.CONTENT_LENGTH; import static org.springframework.http.HttpHeaders.CONTENT_LENGTH;
import lombok.extern.apachecommons.CommonsLog;
/** /**
* @author Dave Syer * @author Dave Syer
* @author Marcos Barbero * @author Marcos Barbero
* @author Spencer Gibb * @author Spencer Gibb
*/ */
@CommonsLog
public class ProxyRequestHelper { public class ProxyRequestHelper {
private static final Log log = LogFactory.getLog(ProxyRequestHelper.class);
/** /**
* Zuul context key for a collection of ignored headers for the current request. * Zuul context key for a collection of ignored headers for the current request.
* Pre-filters can set this up as a set of lowercase strings. * Pre-filters can set this up as a set of lowercase strings.
......
...@@ -24,6 +24,8 @@ import java.util.Map; ...@@ -24,6 +24,8 @@ import java.util.Map;
import java.util.Map.Entry; import java.util.Map.Entry;
import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReference;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.cloud.netflix.zuul.filters.ZuulProperties.ZuulRoute; import org.springframework.cloud.netflix.zuul.filters.ZuulProperties.ZuulRoute;
import org.springframework.cloud.netflix.zuul.util.RequestUtils; import org.springframework.cloud.netflix.zuul.util.RequestUtils;
import org.springframework.core.Ordered; import org.springframework.core.Ordered;
...@@ -31,15 +33,15 @@ import org.springframework.util.AntPathMatcher; ...@@ -31,15 +33,15 @@ import org.springframework.util.AntPathMatcher;
import org.springframework.util.PathMatcher; import org.springframework.util.PathMatcher;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;
import lombok.extern.apachecommons.CommonsLog;
/** /**
* Simple {@link RouteLocator} based on configuration data held in {@link ZuulProperties}. * Simple {@link RouteLocator} based on configuration data held in {@link ZuulProperties}.
* *
* @author Dave Syer * @author Dave Syer
*/ */
@CommonsLog
public class SimpleRouteLocator implements RouteLocator, Ordered { public class SimpleRouteLocator implements RouteLocator, Ordered {
private static final Log log = LogFactory.getLog(SimpleRouteLocator.class);
private static final int DEFAULT_ORDER = 0; private static final int DEFAULT_ORDER = 0;
private ZuulProperties properties; private ZuulProperties properties;
......
...@@ -32,12 +32,9 @@ import org.springframework.util.MultiValueMap; ...@@ -32,12 +32,9 @@ import org.springframework.util.MultiValueMap;
import com.netflix.zuul.context.RequestContext; import com.netflix.zuul.context.RequestContext;
import lombok.extern.apachecommons.CommonsLog;
/** /**
* @author Spencer Gibb * @author Spencer Gibb
*/ */
@CommonsLog
public class TraceProxyRequestHelper extends ProxyRequestHelper { public class TraceProxyRequestHelper extends ProxyRequestHelper {
private TraceRepository traces; private TraceRepository traces;
......
...@@ -21,6 +21,8 @@ import java.util.List; ...@@ -21,6 +21,8 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Map.Entry; import java.util.Map.Entry;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.cloud.netflix.zuul.filters.RefreshableRouteLocator; import org.springframework.cloud.netflix.zuul.filters.RefreshableRouteLocator;
...@@ -31,8 +33,6 @@ import org.springframework.cloud.netflix.zuul.filters.ZuulProperties.ZuulRoute; ...@@ -31,8 +33,6 @@ import org.springframework.cloud.netflix.zuul.filters.ZuulProperties.ZuulRoute;
import org.springframework.util.PatternMatchUtils; import org.springframework.util.PatternMatchUtils;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;
import lombok.extern.apachecommons.CommonsLog;
/** /**
* A {@link RouteLocator} that combines static, configured routes with those from a * A {@link RouteLocator} that combines static, configured routes with those from a
* {@link DiscoveryClient}. The discovery client takes precedence. * {@link DiscoveryClient}. The discovery client takes precedence.
...@@ -40,10 +40,11 @@ import lombok.extern.apachecommons.CommonsLog; ...@@ -40,10 +40,11 @@ import lombok.extern.apachecommons.CommonsLog;
* @author Spencer Gibb * @author Spencer Gibb
* @author Dave Syer * @author Dave Syer
*/ */
@CommonsLog
public class DiscoveryClientRouteLocator extends SimpleRouteLocator public class DiscoveryClientRouteLocator extends SimpleRouteLocator
implements RefreshableRouteLocator { implements RefreshableRouteLocator {
private static final Log log = LogFactory.getLog(DiscoveryClientRouteLocator.class);
public static final String DEFAULT_ROUTE = "/**"; public static final String DEFAULT_ROUTE = "/**";
private DiscoveryClient discovery; private DiscoveryClient discovery;
......
...@@ -67,8 +67,6 @@ import static org.junit.Assert.assertEquals; ...@@ -67,8 +67,6 @@ import static org.junit.Assert.assertEquals;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_TYPE; import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_TYPE;
import static org.springframework.util.StreamUtils.copyToString; import static org.springframework.util.StreamUtils.copyToString;
import lombok.extern.slf4j.Slf4j;
@RunWith(SpringJUnit4ClassRunner.class) @RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = FormZuulProxyApplication.class, webEnvironment = WebEnvironment.RANDOM_PORT, value = { @SpringBootTest(classes = FormZuulProxyApplication.class, webEnvironment = WebEnvironment.RANDOM_PORT, value = {
"zuul.routes.simple:/simple/**" }) "zuul.routes.simple:/simple/**" })
...@@ -229,7 +227,6 @@ public class FormZuulProxyApplicationTests { ...@@ -229,7 +227,6 @@ public class FormZuulProxyApplicationTests {
@RibbonClients({ @RibbonClients({
@RibbonClient(name = "simple", configuration = FormRibbonClientConfiguration.class), @RibbonClient(name = "simple", configuration = FormRibbonClientConfiguration.class),
@RibbonClient(name = "psimple", configuration = FormRibbonClientConfiguration.class) }) @RibbonClient(name = "psimple", configuration = FormRibbonClientConfiguration.class) })
@Slf4j
class FormZuulProxyApplication { class FormZuulProxyApplication {
@RequestMapping(value = "/form", method = RequestMethod.POST) @RequestMapping(value = "/form", method = RequestMethod.POST)
......
...@@ -26,6 +26,8 @@ import com.netflix.loadbalancer.ServerList; ...@@ -26,6 +26,8 @@ import com.netflix.loadbalancer.ServerList;
import com.netflix.zuul.ZuulFilter; import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext; import com.netflix.zuul.context.RequestContext;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.junit.After; import org.junit.After;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
...@@ -64,8 +66,6 @@ import org.springframework.web.multipart.MultipartFile; ...@@ -64,8 +66,6 @@ import org.springframework.web.multipart.MultipartFile;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_TYPE; import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.PRE_TYPE;
import lombok.extern.slf4j.Slf4j;
@RunWith(SpringJUnit4ClassRunner.class) @RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = FormZuulServletProxyApplication.class, webEnvironment = WebEnvironment.RANDOM_PORT, value = "zuul.routes.simple:/simple/**") @SpringBootTest(classes = FormZuulServletProxyApplication.class, webEnvironment = WebEnvironment.RANDOM_PORT, value = "zuul.routes.simple:/simple/**")
@DirtiesContext @DirtiesContext
...@@ -146,9 +146,10 @@ public class FormZuulServletProxyApplicationTests { ...@@ -146,9 +146,10 @@ public class FormZuulServletProxyApplicationTests {
@RestController @RestController
@EnableZuulProxy @EnableZuulProxy
@RibbonClients(@RibbonClient(name = "simple", configuration = ServletFormRibbonClientConfiguration.class)) @RibbonClients(@RibbonClient(name = "simple", configuration = ServletFormRibbonClientConfiguration.class))
@Slf4j
class FormZuulServletProxyApplication { class FormZuulServletProxyApplication {
private static final Log log = LogFactory.getLog(FormZuulServletProxyApplication.class);
@RequestMapping(value = "/form", method = RequestMethod.POST) @RequestMapping(value = "/form", method = RequestMethod.POST)
public String accept(@RequestParam MultiValueMap<String, String> form) public String accept(@RequestParam MultiValueMap<String, String> form)
throws IOException { throws IOException {
......
...@@ -34,8 +34,6 @@ import com.netflix.appinfo.HealthCheckHandler; ...@@ -34,8 +34,6 @@ import com.netflix.appinfo.HealthCheckHandler;
import com.netflix.discovery.EurekaClient; import com.netflix.discovery.EurekaClient;
import com.netflix.discovery.EurekaClientConfig; import com.netflix.discovery.EurekaClientConfig;
import lombok.extern.apachecommons.CommonsLog;
/** /**
* @author Dave Syer * @author Dave Syer
* @author Spencer Gibb * @author Spencer Gibb
...@@ -46,7 +44,6 @@ import lombok.extern.apachecommons.CommonsLog; ...@@ -46,7 +44,6 @@ import lombok.extern.apachecommons.CommonsLog;
@EnableConfigurationProperties @EnableConfigurationProperties
@ConditionalOnClass(EurekaClientConfig.class) @ConditionalOnClass(EurekaClientConfig.class)
@ConditionalOnProperty(value = "eureka.client.enabled", matchIfMissing = true) @ConditionalOnProperty(value = "eureka.client.enabled", matchIfMissing = true)
@CommonsLog
public class EurekaDiscoveryClientConfiguration { public class EurekaDiscoveryClientConfiguration {
class Marker {} class Marker {}
......
...@@ -21,16 +21,17 @@ import java.util.Map; ...@@ -21,16 +21,17 @@ import java.util.Map;
import com.netflix.appinfo.EurekaInstanceConfig; import com.netflix.appinfo.EurekaInstanceConfig;
import com.netflix.appinfo.InstanceInfo; import com.netflix.appinfo.InstanceInfo;
import com.netflix.appinfo.LeaseInfo; import com.netflix.appinfo.LeaseInfo;
import org.apache.commons.logging.Log;
import lombok.extern.apachecommons.CommonsLog; import org.apache.commons.logging.LogFactory;
/** /**
* See com.netflix.appinfo.providers.EurekaConfigBasedInstanceInfoProvider * See com.netflix.appinfo.providers.EurekaConfigBasedInstanceInfoProvider
* @author Spencer Gibb * @author Spencer Gibb
*/ */
@CommonsLog
public class InstanceInfoFactory { public class InstanceInfoFactory {
private static final Log log = LogFactory.getLog(InstanceInfoFactory.class);
public InstanceInfo create(EurekaInstanceConfig config) { public InstanceInfo create(EurekaInstanceConfig config) {
LeaseInfo.Builder leaseInfoBuilder = LeaseInfo.Builder.newBuilder() LeaseInfo.Builder leaseInfoBuilder = LeaseInfo.Builder.newBuilder()
.setRenewalIntervalInSecs(config.getLeaseRenewalIntervalInSeconds()) .setRenewalIntervalInSecs(config.getLeaseRenewalIntervalInSeconds())
......
...@@ -20,6 +20,8 @@ import javax.annotation.PostConstruct; ...@@ -20,6 +20,8 @@ import javax.annotation.PostConstruct;
import javax.inject.Provider; import javax.inject.Provider;
import com.netflix.discovery.EurekaClient; import com.netflix.discovery.EurekaClient;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
...@@ -43,8 +45,6 @@ import static com.netflix.client.config.CommonClientConfigKey.DeploymentContextB ...@@ -43,8 +45,6 @@ import static com.netflix.client.config.CommonClientConfigKey.DeploymentContextB
import static com.netflix.client.config.CommonClientConfigKey.EnableZoneAffinity; import static com.netflix.client.config.CommonClientConfigKey.EnableZoneAffinity;
import static org.springframework.cloud.netflix.ribbon.RibbonUtils.setRibbonProperty; import static org.springframework.cloud.netflix.ribbon.RibbonUtils.setRibbonProperty;
import lombok.extern.apachecommons.CommonsLog;
/** /**
* Preprocessor that configures defaults for eureka-discovered ribbon clients. Such as: * Preprocessor that configures defaults for eureka-discovered ribbon clients. Such as:
* <code>@zone</code>, NIWSServerListClassName, DeploymentContextBasedVipAddresses, * <code>@zone</code>, NIWSServerListClassName, DeploymentContextBasedVipAddresses,
...@@ -55,9 +55,10 @@ import lombok.extern.apachecommons.CommonsLog; ...@@ -55,9 +55,10 @@ import lombok.extern.apachecommons.CommonsLog;
* @author Ryan Baxter * @author Ryan Baxter
*/ */
@Configuration @Configuration
@CommonsLog
public class EurekaRibbonClientConfiguration { public class EurekaRibbonClientConfiguration {
private static final Log log = LogFactory.getLog(EurekaRibbonClientConfiguration.class);
@Value("${ribbon.eureka.approximateZoneFromHostname:false}") @Value("${ribbon.eureka.approximateZoneFromHostname:false}")
private boolean approximateZoneFromHostname = false; private boolean approximateZoneFromHostname = false;
......
...@@ -34,14 +34,16 @@ import com.netflix.eureka.aws.AwsBinderDelegate; ...@@ -34,14 +34,16 @@ import com.netflix.eureka.aws.AwsBinderDelegate;
import com.netflix.eureka.registry.PeerAwareInstanceRegistry; import com.netflix.eureka.registry.PeerAwareInstanceRegistry;
import com.netflix.eureka.util.EurekaMonitors; import com.netflix.eureka.util.EurekaMonitors;
import com.thoughtworks.xstream.XStream; import com.thoughtworks.xstream.XStream;
import org.apache.commons.logging.Log;
import lombok.extern.apachecommons.CommonsLog; import org.apache.commons.logging.LogFactory;
/** /**
* @author Spencer Gibb * @author Spencer Gibb
*/ */
@CommonsLog
public class EurekaServerBootstrap { public class EurekaServerBootstrap {
private static final Log log = LogFactory.getLog(EurekaServerBootstrap.class);
private static final String TEST = "test"; private static final String TEST = "test";
private static final String ARCHAIUS_DEPLOYMENT_ENVIRONMENT = "archaius.deployment.environment"; private static final String ARCHAIUS_DEPLOYMENT_ENVIRONMENT = "archaius.deployment.environment";
......
...@@ -18,6 +18,8 @@ package org.springframework.cloud.netflix.eureka.server; ...@@ -18,6 +18,8 @@ package org.springframework.cloud.netflix.eureka.server;
import javax.servlet.ServletContext; import javax.servlet.ServletContext;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.netflix.eureka.server.event.EurekaRegistryAvailableEvent; import org.springframework.cloud.netflix.eureka.server.event.EurekaRegistryAvailableEvent;
import org.springframework.cloud.netflix.eureka.server.event.EurekaServerStartedEvent; import org.springframework.cloud.netflix.eureka.server.event.EurekaServerStartedEvent;
...@@ -30,16 +32,15 @@ import org.springframework.web.context.ServletContextAware; ...@@ -30,16 +32,15 @@ import org.springframework.web.context.ServletContextAware;
import com.netflix.eureka.EurekaServerConfig; import com.netflix.eureka.EurekaServerConfig;
import lombok.extern.apachecommons.CommonsLog;
/** /**
* @author Dave Syer * @author Dave Syer
*/ */
@Configuration @Configuration
@CommonsLog
public class EurekaServerInitializerConfiguration public class EurekaServerInitializerConfiguration
implements ServletContextAware, SmartLifecycle, Ordered { implements ServletContextAware, SmartLifecycle, Ordered {
private static final Log log = LogFactory.getLog(EurekaServerInitializerConfiguration.class);
@Autowired @Autowired
private EurekaServerConfig eurekaServerConfig; private EurekaServerConfig eurekaServerConfig;
......
...@@ -19,6 +19,8 @@ package org.springframework.cloud.netflix.eureka.server; ...@@ -19,6 +19,8 @@ package org.springframework.cloud.netflix.eureka.server;
import java.util.List; import java.util.List;
import com.netflix.eureka.lease.Lease; import com.netflix.eureka.lease.Lease;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.BeansException; import org.springframework.beans.BeansException;
import org.springframework.cloud.netflix.eureka.server.event.EurekaInstanceCanceledEvent; import org.springframework.cloud.netflix.eureka.server.event.EurekaInstanceCanceledEvent;
import org.springframework.cloud.netflix.eureka.server.event.EurekaInstanceRegisteredEvent; import org.springframework.cloud.netflix.eureka.server.event.EurekaInstanceRegisteredEvent;
...@@ -35,16 +37,16 @@ import com.netflix.eureka.EurekaServerConfig; ...@@ -35,16 +37,16 @@ import com.netflix.eureka.EurekaServerConfig;
import com.netflix.eureka.registry.PeerAwareInstanceRegistryImpl; import com.netflix.eureka.registry.PeerAwareInstanceRegistryImpl;
import com.netflix.eureka.resources.ServerCodecs; import com.netflix.eureka.resources.ServerCodecs;
import lombok.extern.apachecommons.CommonsLog;
import org.springframework.context.ApplicationEvent; import org.springframework.context.ApplicationEvent;
/** /**
* @author Spencer Gibb * @author Spencer Gibb
*/ */
@CommonsLog
public class InstanceRegistry extends PeerAwareInstanceRegistryImpl public class InstanceRegistry extends PeerAwareInstanceRegistryImpl
implements ApplicationContextAware { implements ApplicationContextAware {
private static final Log log = LogFactory.getLog(InstanceRegistry.class);
private ApplicationContext ctxt; private ApplicationContext ctxt;
private int defaultOpenForTrafficCount; private int defaultOpenForTrafficCount;
......
...@@ -135,6 +135,7 @@ public class HystrixDashboardConfiguration { ...@@ -135,6 +135,7 @@ public class HystrixDashboardConfiguration {
response.getWriter() response.getWriter()
.println( .println(
"Required parameter 'origin' missing. Example: 107.20.175.135:7001"); "Required parameter 'origin' missing. Example: 107.20.175.135:7001");
return;
} }
origin = origin.trim(); origin = origin.trim();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment