public class RemoveWatchesBuilderImpl extends Object implements RemoveWatchesBuilder, RemoveWatchesType, RemoveWatchesLocal, ErrorListenerPathable<Void>
Constructor and Description |
---|
RemoveWatchesBuilderImpl(CuratorFrameworkImpl client) |
RemoveWatchesBuilderImpl(CuratorFrameworkImpl client,
org.apache.zookeeper.Watcher watcher,
CuratorWatcher curatorWatcher,
org.apache.zookeeper.Watcher.WatcherType watcherType,
boolean guaranteed,
boolean local,
boolean quietly,
Backgrounding backgrounding) |
Modifier and Type | Method and Description |
---|---|
Void |
forPath(String path)
Commit the currently building operation using the given path
|
protected CuratorFrameworkImpl |
getClient() |
RemoveWatchesLocal |
guaranteed()
Solves edge cases where an operation may succeed on the server but connection failure occurs before a
response can be successfully returned to the client.
|
ErrorListenerPathable<Void> |
inBackground()
Perform the action in the background
|
ErrorListenerPathable<Void> |
inBackground(BackgroundCallback callback)
Perform the action in the background
|
ErrorListenerPathable<Void> |
inBackground(BackgroundCallback callback,
Executor executor)
Perform the action in the background
|
ErrorListenerPathable<Void> |
inBackground(BackgroundCallback callback,
Object context)
Perform the action in the background
|
ErrorListenerPathable<Void> |
inBackground(BackgroundCallback callback,
Object context,
Executor executor)
Perform the action in the background
|
ErrorListenerPathable<Void> |
inBackground(Object context)
Perform the action in the background
|
BackgroundPathableQuietlyable<Void> |
locally()
Specify if the client should just remove client side watches if a connection to ZK
is not available.
|
RemoveWatchesLocal |
ofType(org.apache.zookeeper.Watcher.WatcherType watcherType)
Specify the type of watcher to be removed.
|
void |
performBackgroundOperation(org.apache.curator.framework.imps.OperationAndData<String> operationAndData) |
BackgroundPathable<Void> |
quietly() |
RemoveWatchesType |
remove(CuratorWatcher watcher)
Specify the watcher to be removed
|
RemoveWatchesType |
remove(org.apache.zookeeper.Watcher watcher)
Specify the watcher to be removed
|
RemoveWatchesType |
removeAll()
Specify that all watches should be removed
|
Pathable<Void> |
withUnhandledErrorListener(UnhandledErrorListener listener)
Set an error listener for this background operation.
|
public RemoveWatchesBuilderImpl(CuratorFrameworkImpl client)
public RemoveWatchesBuilderImpl(CuratorFrameworkImpl client, org.apache.zookeeper.Watcher watcher, CuratorWatcher curatorWatcher, org.apache.zookeeper.Watcher.WatcherType watcherType, boolean guaranteed, boolean local, boolean quietly, Backgrounding backgrounding)
public RemoveWatchesType remove(org.apache.zookeeper.Watcher watcher)
RemoveWatchesBuilder
remove
in interface RemoveWatchesBuilder
public RemoveWatchesType remove(CuratorWatcher watcher)
RemoveWatchesBuilder
remove
in interface RemoveWatchesBuilder
public RemoveWatchesType removeAll()
RemoveWatchesBuilder
removeAll
in interface RemoveWatchesBuilder
public RemoveWatchesLocal ofType(org.apache.zookeeper.Watcher.WatcherType watcherType)
RemoveWatchesType
ofType
in interface RemoveWatchesType
public ErrorListenerPathable<Void> inBackground(BackgroundCallback callback, Object context)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<Void>>
callback
- a functor that will get called when the operation has completedcontext
- context object - will be available from the event sent to the listenerpublic ErrorListenerPathable<Void> inBackground(BackgroundCallback callback, Object context, Executor executor)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<Void>>
callback
- a functor that will get called when the operation has completedcontext
- context object - will be available from the event sent to the listenerexecutor
- executor to use for the background callpublic ErrorListenerPathable<Void> inBackground(BackgroundCallback callback)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<Void>>
callback
- a functor that will get called when the operation has completedpublic ErrorListenerPathable<Void> inBackground(BackgroundCallback callback, Executor executor)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<Void>>
callback
- a functor that will get called when the operation has completedexecutor
- executor to use for the background callpublic ErrorListenerPathable<Void> inBackground()
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<Void>>
public ErrorListenerPathable<Void> inBackground(Object context)
Backgroundable
inBackground
in interface Backgroundable<ErrorListenerPathable<Void>>
context
- context object - will be available from the event sent to the listenerpublic Pathable<Void> withUnhandledErrorListener(UnhandledErrorListener listener)
ErrorListenerPathable
withUnhandledErrorListener
in interface ErrorListenerPathable<Void>
listener
- the listenerpublic RemoveWatchesLocal guaranteed()
Guaranteeable
guaranteed
in interface Guaranteeable<BackgroundPathableQuietlyable<Void>>
GuaranteeableDeletable
public BackgroundPathableQuietlyable<Void> locally()
RemoveWatchesLocal
locally
in interface RemoveWatchesLocal
public BackgroundPathable<Void> quietly()
quietly
in interface Quietly<BackgroundPathable<Void>>
public Void forPath(String path) throws Exception
Pathable
protected CuratorFrameworkImpl getClient()
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.