OpflowRpcWatcher (opflow-core 0.3.0 API)

java.lang.Object

com.devebot.opflow.OpflowRpcWatcher

All Implemented Interfaces:: AutoCloseable

public class OpflowRpcWatcher
extends Object
implements AutoCloseable

Author:: acegik

Nested Class Summary

Nested Classes

Modifier and Type Class Description

class OpflowRpcWatcher.MyTimerTask
Field Summary

Fields

Modifier and Type Field Description

static long RPC_DETECTION_INTERVAL

Constructor Summary

Constructors
Constructor	Description
`OpflowRpcWatcher(Map<String,OpflowConnector> _connectors)`
`OpflowRpcWatcher(Map<String,OpflowConnector> _connectors, OpflowGarbageCollector _garbageCollector, Map<String,Object> kwargs)`
`OpflowRpcWatcher(Map<String,OpflowConnector> _connectors, Map<String,Object> kwargs)`

Method Summary

Modifier and Type Method Description

void close()

long getCount()

long getInterval()

boolean isEnabled()

void serve()

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(Map<String,OpflowConnector> _connectors)
- OpflowRpcWatcher
  
  public OpflowRpcWatcher(Map<String,OpflowConnector> _connectors, Map<String,Object> kwargs)
- OpflowRpcWatcher
  
  public OpflowRpcWatcher(Map<String,OpflowConnector> _connectors, OpflowGarbageCollector _garbageCollector, Map<String,Object> kwargs)
Method Details
- getCount
  
  public long getCount()
- isEnabled
  
  public boolean isEnabled()
- getInterval
  
  public long getInterval()
- serve
  
  public void serve()
- close
  
  public void close()
  
  Specified by:
  
  close in interface AutoCloseable