Class CuratorFrameworkFactoryBean
java.lang.Object
org.springframework.integration.zookeeper.config.CuratorFrameworkFactoryBean
- All Implemented Interfaces:
org.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle
public class CuratorFrameworkFactoryBean
extends Object
implements org.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>, org.springframework.context.SmartLifecycle
A Spring-friendly way to build a
CuratorFramework and implementing SmartLifecycle.- Since:
- 4.2
-
Field Summary
Fields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTEFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsConstructorDescriptionCuratorFrameworkFactoryBean(String connectionString) Construct an instance using the supplied connection string and using a default retry policynew ExponentialBackoffRetry(1000, 3).CuratorFrameworkFactoryBean(String connectionString, org.apache.curator.RetryPolicy retryPolicy) Construct an instance using the supplied connection string and retry policy. -
Method Summary
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.beans.factory.FactoryBean
isSingletonMethods inherited from interface org.springframework.context.SmartLifecycle
stop
-
Constructor Details
-
CuratorFrameworkFactoryBean
Construct an instance using the supplied connection string and using a default retry policynew ExponentialBackoffRetry(1000, 3).- Parameters:
connectionString- list of servers to connect to
-
CuratorFrameworkFactoryBean
public CuratorFrameworkFactoryBean(String connectionString, org.apache.curator.RetryPolicy retryPolicy) Construct an instance using the supplied connection string and retry policy.- Parameters:
connectionString- list of servers to connect toretryPolicy- the retry policy
-
-
Method Details
-
getPhase
public int getPhase()- Specified by:
getPhasein interfaceorg.springframework.context.Phased- Specified by:
getPhasein interfaceorg.springframework.context.SmartLifecycle
-
setPhase
public void setPhase(int phase) - Parameters:
phase- the phase- See Also:
-
SmartLifecycle
-
isRunning
public boolean isRunning()- Specified by:
isRunningin interfaceorg.springframework.context.Lifecycle
-
isAutoStartup
public boolean isAutoStartup()- Specified by:
isAutoStartupin interfaceorg.springframework.context.SmartLifecycle
-
setAutoStartup
public void setAutoStartup(boolean autoStartup) - Parameters:
autoStartup- true to automatically start- See Also:
-
SmartLifecycle
-
start
public void start()- Specified by:
startin interfaceorg.springframework.context.Lifecycle
-
stop
public void stop()- Specified by:
stopin interfaceorg.springframework.context.Lifecycle
-
getObject
public org.apache.curator.framework.CuratorFramework getObject()- Specified by:
getObjectin interfaceorg.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>
-
getObjectType
- Specified by:
getObjectTypein interfaceorg.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>
-