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 java.lang.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
-
Constructor Summary
Constructors Constructor Description CuratorFrameworkFactoryBean(java.lang.String connectionString)Construct an instance using the supplied connection string and using a default retry policynew ExponentialBackoffRetry(1000, 3).CuratorFrameworkFactoryBean(java.lang.String connectionString, org.apache.curator.RetryPolicy retryPolicy)Construct an instance using the supplied connection string and retry policy. -
Method Summary
Modifier and Type Method Description org.apache.curator.framework.CuratorFrameworkgetObject()java.lang.Class<?>getObjectType()intgetPhase()booleanisAutoStartup()booleanisRunning()voidsetAutoStartup(boolean autoStartup)voidsetPhase(int phase)voidstart()voidstop()
-
Constructor Details
-
CuratorFrameworkFactoryBean
public CuratorFrameworkFactoryBean(java.lang.String connectionString)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(java.lang.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
public java.lang.Class<?> getObjectType()- Specified by:
getObjectTypein interfaceorg.springframework.beans.factory.FactoryBean<org.apache.curator.framework.CuratorFramework>
-