org.adroitlogic.x.clustering

Class CommandStatusReporter

java.lang.Object

org.adroitlogic.x.clustering.CommandStatusReporter

All Implemented Interfaces:

org.apache.curator.framework.api.BackgroundCallback, org.apache.zookeeper.Watcher

public class CommandStatusReporter
extends Object
implements org.apache.curator.framework.api.BackgroundCallback, org.apache.zookeeper.Watcher

The class which is responsible for reporting successes and failures of a control commands. This class make use of the curator client and the BackgroundCallback functionality of curator API

Since:

17.01

Author:

Imesha Sudasingha

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.zookeeper.Watcher

org.apache.zookeeper.Watcher.Event, org.apache.zookeeper.Watcher.WatcherType

Constructor Summary

Constructors

Constructor and Description
CommandStatusReporter(org.apache.curator.framework.CuratorFramework client, String reportPath)

Method Summary

Modifier and Type	Method and Description
void	process(org.apache.zookeeper.WatchedEvent event)
void	processResult(org.apache.curator.framework.CuratorFramework client, org.apache.curator.framework.api.CuratorEvent event)
void	report() creates a ZNode in background in the

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandStatusReporter

public CommandStatusReporter(org.apache.curator.framework.CuratorFramework client,
                             String reportPath)

Method Detail

report

public void report()
            throws Exception

creates a ZNode in background in the

reportPath

with the name

nodeName

Throws:

Exception - zookeeper errors etc...

processResult

public void processResult(org.apache.curator.framework.CuratorFramework client,
                          org.apache.curator.framework.api.CuratorEvent event)
                   throws Exception

Specified by:

processResult in interface org.apache.curator.framework.api.BackgroundCallback

Throws:

Exception

process

public void process(org.apache.zookeeper.WatchedEvent event)

Specified by:

process in interface org.apache.zookeeper.Watcher