net.bluemind.backend.cyrus.syncclient.mgmt

Class SyncClientMgmt

java.lang.Object

net.bluemind.backend.cyrus.syncclient.mgmt.SyncClientMgmt

All Implemented Interfaces:

ISyncClientMgmt, ProcessHandler

public class SyncClientMgmt
extends java.lang.Object
implements ISyncClientMgmt, ProcessHandler

Nested Class Summary

Nested classes/interfaces inherited from interface net.bluemind.backend.cyrus.syncclient.mgmt.api.ISyncClientMgmt

ISyncClientMgmt.SyncClientMgmtBuilder

Nested classes/interfaces inherited from interface net.bluemind.node.api.ProcessHandler

ProcessHandler.BlockingHandler, ProcessHandler.NoOutBlockingHandler

Constructor Summary

Constructors

Constructor and Description
SyncClientMgmt(io.vertx.core.Vertx vertx, java.lang.String cyrusBackendAddress, java.lang.String replicationChannel, int shardIndex, java.util.List<ISyncClientObserver> obs, java.util.concurrent.Executor observersPool)

Method Summary

Modifier and Type	Method and Description
void	completed(int exitCode)
void	log(java.lang.String l, boolean cont)
void	starting(java.lang.String taskRef)
void	startRollingReplication() Starts, or restarts, rolling replication
void	stopRollingReplication()

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.bluemind.backend.cyrus.syncclient.mgmt.api.ISyncClientMgmt

builder

Constructor Detail

SyncClientMgmt

public SyncClientMgmt(io.vertx.core.Vertx vertx,
                      java.lang.String cyrusBackendAddress,
                      java.lang.String replicationChannel,
                      int shardIndex,
                      java.util.List<ISyncClientObserver> obs,
                      java.util.concurrent.Executor observersPool)

Method Detail

startRollingReplication

public void startRollingReplication()

Description copied from interface: ISyncClientMgmt

Starts, or restarts, rolling replication

Specified by:

startRollingReplication in interface ISyncClientMgmt

stopRollingReplication

public void stopRollingReplication()

Specified by:

stopRollingReplication in interface ISyncClientMgmt

log

public void log(java.lang.String l,
                boolean cont)

Specified by:

log in interface ProcessHandler

cont - is true when the line was longer than our max frame size. The received line did not end with a line-feed in the original output

completed

public void completed(int exitCode)

Specified by:

completed in interface ProcessHandler

starting

public void starting(java.lang.String taskRef)

Specified by:

starting in interface ProcessHandler