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

remove Lombok

Browse Source
This commit is contained in:
Oleg Vyukov
2018-02-24 20:52:33 +03:00
parent 34e8e7d0f0
commit 0ea4d0b6ad
2 changed files with 6 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
spring-cloud-kubernetes-discovery/pom.xml
View File

@@ -52,13 +52,6 @@
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<!-- Only needed at compile time -->
<scope>provided</scope>
</dependency>
<!-- Testing Dependencies -->
<dependency>
<groupId>org.springframework.boot</groupId>

10
spring-cloud-kubernetes-discovery/src/main/java/org/springframework/cloud/kubernetes/discovery/KubernetesCatalogWatch.java
View File

@@ -16,7 +16,8 @@
package org.springframework.cloud.kubernetes.discovery;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.client.discovery.event.HeartbeatEvent;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
@@ -29,9 +30,10 @@ import java.util.concurrent.atomic.AtomicReference;
/**
* @author Oleg Vyukov
*/
@Slf4j
public class KubernetesCatalogWatch implements ApplicationEventPublisherAware {
private static final Logger logger = LoggerFactory.getLogger(KubernetesCatalogWatch.class);
private final KubernetesDiscoveryClient kubernetesDiscoveryClient;
private final AtomicReference<List<String>> catalogServicesState = new AtomicReference<>();
private ApplicationEventPublisher publisher;
@@ -56,11 +58,11 @@ public class KubernetesCatalogWatch implements ApplicationEventPublisherAware {
catalogServicesState.set(services);
if (!services.equals(previousState)) {
log.trace("Received services update from kubernetesDiscoveryClient: {}", services);
logger.trace("Received services update from kubernetesDiscoveryClient: {}", services);
publisher.publishEvent(new HeartbeatEvent(this, services));
}
} catch (Exception e) {
log.error("Error watching Kubernetes Services", e);
logger.error("Error watching Kubernetes Services", e);
}
}
}