com.lucidworks.apollo.component

Class CuratorComponent

java.lang.Object

com.lucidworks.apollo.component.CuratorComponent

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class CuratorComponent
extends java.lang.Object
implements java.io.Closeable

Manages CuratorFramework instances for the application.

Constructor Summary

Constructors

Constructor and Description
CuratorComponent(com.lucidworks.apollo.startup.DependencyManager dependencyManager, com.lucidworks.apollo.config.CuratorConfiguration configuration, MetricRegistry metricRegistry, com.lucidworks.apollo.component.CuratorComponent.InstrumentedBoundedExponentialBackoffRetry retryPolicy, CuratorDependencyComponent curatorDependencyComponent)

Method Summary

Modifier and Type	Method and Description
void	close()
CuratorFramework	get() Get an active, initialized CuratorFramework with a namespace set
java.lang.String	getZkConnect()
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

CuratorComponent

public CuratorComponent(com.lucidworks.apollo.startup.DependencyManager dependencyManager,
                        com.lucidworks.apollo.config.CuratorConfiguration configuration,
                        MetricRegistry metricRegistry,
                        com.lucidworks.apollo.component.CuratorComponent.InstrumentedBoundedExponentialBackoffRetry retryPolicy,
                        CuratorDependencyComponent curatorDependencyComponent)

Method Detail

get

public CuratorFramework get()

Get an active, initialized CuratorFramework with a namespace set

Returns:

getZkConnect

public java.lang.String getZkConnect()

shutdown

@PreDestroy
public void shutdown()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException