org.springframework.cloud.zookeeper.discovery

Class ZookeeperServiceDiscovery

java.lang.Object

org.springframework.cloud.zookeeper.discovery.ZookeeperServiceDiscovery

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

public class ZookeeperServiceDiscovery
extends Object
implements org.springframework.context.ApplicationContextAware

Service discovery for Zookeeper that sets up ServiceDiscovery and ServiceInstance.

Since:

1.0.0

Author:

Spencer Gibb

Constructor Summary

Constructors

Constructor and Description
ZookeeperServiceDiscovery(org.apache.curator.framework.CuratorFramework curator, ZookeeperDiscoveryProperties properties, org.apache.curator.x.discovery.details.InstanceSerializer<ZookeeperInstance> instanceSerializer)

Method Summary

Modifier and Type	Method and Description
void	build()
protected void	configureServiceDiscovery(AtomicReference<org.apache.curator.x.discovery.ServiceDiscovery<ZookeeperInstance>> serviceDiscovery, org.apache.curator.framework.CuratorFramework curator, ZookeeperDiscoveryProperties properties, org.apache.curator.x.discovery.details.InstanceSerializer<ZookeeperInstance> instanceSerializer, AtomicReference<org.apache.curator.x.discovery.ServiceInstance<ZookeeperInstance>> serviceInstance) One can override this method to provide custom way of registering ServiceDiscovery
protected void	configureServiceInstance(AtomicReference<org.apache.curator.x.discovery.ServiceInstance<ZookeeperInstance>> serviceInstance, String appName, org.springframework.context.ApplicationContext context, AtomicInteger port, String host, org.apache.curator.x.discovery.UriSpec uriSpec) One can override this method to provide custom way of registering a service instance (e.g.
protected AtomicBoolean	getBuilt()
protected org.apache.curator.framework.CuratorFramework	getCurator()
int	getPort()
org.apache.curator.x.discovery.ServiceDiscovery<ZookeeperInstance>	getServiceDiscovery()
protected AtomicReference<org.apache.curator.x.discovery.ServiceDiscovery<ZookeeperInstance>>	getServiceDiscoveryRef()
org.apache.curator.x.discovery.ServiceInstance<ZookeeperInstance>	getServiceInstance()
protected AtomicReference<org.apache.curator.x.discovery.ServiceInstance<ZookeeperInstance>>	getServiceInstanceRef()
void	setApplicationContext(org.springframework.context.ApplicationContext context)
void	setPort(int port)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZookeeperServiceDiscovery

public ZookeeperServiceDiscovery(org.apache.curator.framework.CuratorFramework curator,
                                 ZookeeperDiscoveryProperties properties,
                                 org.apache.curator.x.discovery.details.InstanceSerializer<ZookeeperInstance> instanceSerializer)

Method Detail

getPort

public int getPort()

setPort

public void setPort(int port)

getServiceInstance

public org.apache.curator.x.discovery.ServiceInstance<ZookeeperInstance> getServiceInstance()

getServiceDiscovery

public org.apache.curator.x.discovery.ServiceDiscovery<ZookeeperInstance> getServiceDiscovery()

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext context)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

build

public void build()

configureServiceInstance

protected void configureServiceInstance(AtomicReference<org.apache.curator.x.discovery.ServiceInstance<ZookeeperInstance>> serviceInstance,
                                        String appName,
                                        org.springframework.context.ApplicationContext context,
                                        AtomicInteger port,
                                        String host,
                                        org.apache.curator.x.discovery.UriSpec uriSpec)

One can override this method to provide custom way of registering a service instance (e.g. when no payload is required).

configureServiceDiscovery

protected void configureServiceDiscovery(AtomicReference<org.apache.curator.x.discovery.ServiceDiscovery<ZookeeperInstance>> serviceDiscovery,
                                         org.apache.curator.framework.CuratorFramework curator,
                                         ZookeeperDiscoveryProperties properties,
                                         org.apache.curator.x.discovery.details.InstanceSerializer<ZookeeperInstance> instanceSerializer,
                                         AtomicReference<org.apache.curator.x.discovery.ServiceInstance<ZookeeperInstance>> serviceInstance)

One can override this method to provide custom way of registering ServiceDiscovery

getServiceDiscoveryRef

protected AtomicReference<org.apache.curator.x.discovery.ServiceDiscovery<ZookeeperInstance>> getServiceDiscoveryRef()

getServiceInstanceRef

protected AtomicReference<org.apache.curator.x.discovery.ServiceInstance<ZookeeperInstance>> getServiceInstanceRef()

getBuilt

protected AtomicBoolean getBuilt()

getCurator

protected org.apache.curator.framework.CuratorFramework getCurator()