com.netflix.curator.framework.state
Class ConnectionStateManager

java.lang.Object
  com.netflix.curator.framework.state.ConnectionStateManager

All Implemented Interfaces:

Closeable

public class ConnectionStateManager
extends Object
implements Closeable

Used internally to manage connection state

Constructor Summary

ConnectionStateManager(CuratorFramework client)

Method Summary

void	addStateChange(ConnectionState newState) Post a state change.
void	close()
ListenerContainer<ConnectionStateListener>	getListenable() Return the listenable
void	start() Start the manager

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionStateManager

public ConnectionStateManager(CuratorFramework client)

Parameters:

client - the client

Method Detail

start

public void start()

Start the manager

close

public void close()

Specified by:

close in interface Closeable

getListenable

public ListenerContainer<ConnectionStateListener> getListenable()

Return the listenable

Returns:

listenable

addStateChange

public void addStateChange(ConnectionState newState)

Post a state change. If the manager is already in that state the change is ignored. Otherwise the change is queued for listeners.

Parameters:

newState - new state