Package org.apache.curator.framework.recipes

Class AfterConnectionEstablished

java.lang.Object

org.apache.curator.framework.recipes.AfterConnectionEstablished

public class AfterConnectionEstablished
extends Object

Utility class to allow execution of logic once a ZooKeeper connection becomes available.

Method Summary

Modifier and Type	Method	Description
static Future<?>	execute(CuratorFramework client, Runnable runAfterConnection)	Spawns a new new background thread that will block until a connection is available and then execute the 'runAfterConnection' logic

Methods inherited from class java.lang.Object

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

Method Details

execute

public static Future<?> execute(CuratorFramework client,
 Runnable runAfterConnection)
                         throws Exception

Spawns a new new background thread that will block until a connection is available and then execute the 'runAfterConnection' logic

Parameters:

client - The curator client

runAfterConnection - The logic to run

Returns:

future of the task so it can be canceled, etc. if needed

Throws:

Exception