org.springframework.xd.dirt.stream.zookeeper

Class RepositoryConnectionListener

java.lang.Object

org.springframework.xd.dirt.stream.zookeeper.RepositoryConnectionListener

All Implemented Interfaces:

ZooKeeperConnectionListener

public class RepositoryConnectionListener
extends java.lang.Object
implements ZooKeeperConnectionListener

ZooKeeper connection listener that ensures path creation for nodes required by the various repository implementations that use ZooKeeper.

Author:

Patrick Peralta, David Turanski

Constructor Summary

Constructors

Constructor and Description
RepositoryConnectionListener()

Method Summary

Methods

Modifier and Type	Method and Description
void	onConnect(org.apache.curator.framework.CuratorFramework client) Called when the Curator ConnectionStateListener receives a ConnectionState.CONNECTED event.
void	onDisconnect(org.apache.curator.framework.CuratorFramework client) Called when the Curator ConnectionStateListener receives a ConnectionState.LOST event.
void	onResume(org.apache.curator.framework.CuratorFramework client) Called when the Curator ConnectionStateListener receives a ConnectionState.RECONNECTED event.
void	onSuspend(org.apache.curator.framework.CuratorFramework client) Called when the Curator ConnectionStateListener receives a ConnectionState.SUSPENDED event.

Methods inherited from class java.lang.Object

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

Constructor Detail

RepositoryConnectionListener

public RepositoryConnectionListener()

Method Detail

onConnect

public void onConnect(org.apache.curator.framework.CuratorFramework client)

Called when the Curator ConnectionStateListener receives a ConnectionState.CONNECTED event.

Specified by:

onConnect in interface ZooKeeperConnectionListener

Parameters:

client - the CuratorFramework instance

onResume

public void onResume(org.apache.curator.framework.CuratorFramework client)

Called when the Curator ConnectionStateListener receives a ConnectionState.RECONNECTED event.

Specified by:

onResume in interface ZooKeeperConnectionListener

Parameters:

client - the CuratorFramework instance

onDisconnect

public void onDisconnect(org.apache.curator.framework.CuratorFramework client)

Called when the Curator ConnectionStateListener receives a ConnectionState.LOST event.

Specified by:

onDisconnect in interface ZooKeeperConnectionListener

Parameters:

client - the CuratorFramework instance

onSuspend

public void onSuspend(org.apache.curator.framework.CuratorFramework client)

Called when the Curator ConnectionStateListener receives a ConnectionState.SUSPENDED event.

Specified by:

onSuspend in interface ZooKeeperConnectionListener

Parameters:

client - the CuratorFramework instance