Package com.devebot.opflow

Class OpflowRpcWatcher

java.lang.Object

com.devebot.opflow.OpflowRpcWatcher

All Implemented Interfaces:

AutoCloseable

public class OpflowRpcWatcher
extends Object
implements AutoCloseable

Author:

acegik

Field Summary

Fields

Modifier and Type	Field	Description
static long	RPC_DETECTION_INTERVAL

Constructor Summary

Constructors

Constructor	Description
OpflowRpcWatcher(OpflowRpcChecker _rpcChecker)
OpflowRpcWatcher(OpflowRpcChecker _rpcChecker, Map<String,Object> kwargs)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isCongested()
void	setCongested(boolean _congested)
void	start()

Methods inherited from class java.lang.Object

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

Field Details

RPC_DETECTION_INTERVAL

public static final long RPC_DETECTION_INTERVAL

See Also:

Constant Field Values

Constructor Details

OpflowRpcWatcher

public OpflowRpcWatcher(OpflowRpcChecker _rpcChecker)

OpflowRpcWatcher

public OpflowRpcWatcher(OpflowRpcChecker _rpcChecker, Map<String,Object> kwargs)

Method Details

isCongested

public boolean isCongested()

setCongested

public void setCongested(boolean _congested)

start

public void start()

close

public void close()

Specified by:

close in interface AutoCloseable