diff --git a/pom.xml b/pom.xml index 6e5ef6f4..63a8e3cc 100644 --- a/pom.xml +++ b/pom.xml @@ -14,7 +14,7 @@ org.springframework.cloud spring-cloud-build - 1.0.0.BUILD-SNAPSHOT + 1.0.1.BUILD-SNAPSHOT @@ -57,32 +57,32 @@ org.springframework.cloud spring-cloud-zookeeper-core - 1.0.0.BUILD-SNAPSHOT + ${project.version} org.springframework.cloud spring-cloud-zookeeper-bus - 1.0.0.BUILD-SNAPSHOT + ${project.version} org.springframework.cloud spring-cloud-zookeeper-config - 1.0.0.BUILD-SNAPSHOT + ${project.version} org.springframework.cloud spring-cloud-zookeeper-discovery - 1.0.0.BUILD-SNAPSHOT + ${project.version} org.springframework.cloud spring-cloud-commons - 1.0.0.BUILD-SNAPSHOT + ${spring.cloud.commons} org.springframework.cloud spring-cloud-bus - 1.0.0.BUILD-SNAPSHOT + ${spring.cloud.bus} org.springframework.boot @@ -112,12 +112,12 @@ org.springframework.cloud spring-cloud-config-client - 1.0.0.BUILD-SNAPSHOT + ${spring.cloud.config.client} org.springframework.cloud spring-cloud-netflix-core - 1.0.0.BUILD-SNAPSHOT + ${spring.cloud.netflix.core} org.apache.curator @@ -165,6 +165,10 @@ + 1.0.1.BUILD-SNAPSHOT + 1.0.1.BUILD-SNAPSHOT + 1.0.1.BUILD-SNAPSHOT + 1.0.1.BUILD-SNAPSHOT 2.7.0 2.0-RC9 diff --git a/spring-cloud-zookeeper-config/src/main/java/org/springframework/cloud/zookeeper/config/ZookeeperPropertySourceLocator.java b/spring-cloud-zookeeper-config/src/main/java/org/springframework/cloud/zookeeper/config/ZookeeperPropertySourceLocator.java index 948d6656..3acc04e0 100644 --- a/spring-cloud-zookeeper-config/src/main/java/org/springframework/cloud/zookeeper/config/ZookeeperPropertySourceLocator.java +++ b/spring-cloud-zookeeper-config/src/main/java/org/springframework/cloud/zookeeper/config/ZookeeperPropertySourceLocator.java @@ -8,7 +8,8 @@ import javax.annotation.PreDestroy; import org.apache.curator.framework.CuratorFramework; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.cloud.config.client.PropertySourceLocator; +// import org.springframework.cloud.config.client.PropertySourceLocator; +import org.springframework.cloud.bootstrap.config.PropertySourceLocator; import org.springframework.core.env.CompositePropertySource; import org.springframework.core.env.ConfigurableEnvironment; import org.springframework.core.env.Environment; diff --git a/spring-cloud-zookeeper-discovery/src/main/java/org/springframework/cloud/zookeeper/discovery/ZookeeperDiscoveryClient.java b/spring-cloud-zookeeper-discovery/src/main/java/org/springframework/cloud/zookeeper/discovery/ZookeeperDiscoveryClient.java index 67d1dcd7..e03ed7bc 100644 --- a/spring-cloud-zookeeper-discovery/src/main/java/org/springframework/cloud/zookeeper/discovery/ZookeeperDiscoveryClient.java +++ b/spring-cloud-zookeeper-discovery/src/main/java/org/springframework/cloud/zookeeper/discovery/ZookeeperDiscoveryClient.java @@ -41,7 +41,7 @@ public class ZookeeperDiscoveryClient implements DiscoveryClient { + context.getId()); } return new DefaultServiceInstance(instance.getId(), instance.getAddress(), - instance.getPort()); + instance.getPort(), instance.getSslPort()!=null); } @Override @@ -55,26 +55,26 @@ public class ZookeeperDiscoveryClient implements DiscoveryClient { for (ServiceInstance instance : zkInstances) { instances.add(new DefaultServiceInstance(serviceId, instance.getAddress(), - instance.getPort())); + instance.getPort(), instance.getSslPort()!=null)); } return instances; } - @Override - @SneakyThrows - public List getAllInstances() { - List instances = new ArrayList<>(); - - for (String name : discovery.queryForNames()) { - for (ServiceInstance instance: discovery.queryForInstances(name)) { - instances.add(new DefaultServiceInstance(instance.getName(), instance - .getAddress(), instance.getPort())); - } - } - - return instances; - } +// @Override +// @SneakyThrows +// public List getAllInstances() { +// List instances = new ArrayList<>(); +// +// for (String name : discovery.queryForNames()) { +// for (ServiceInstance instance: discovery.queryForInstances(name)) { +// instances.add(new DefaultServiceInstance(instance.getName(), instance +// .getAddress(), instance.getPort(), instance.getSslPort()!=null)); +// } +// } +// +// return instances; +// } @Override public List getServices() {