OpflowConnector (opflow-core 0.3.0 API)

java.lang.Object

com.devebot.opflow.OpflowConnector

public class OpflowConnector
extends Object

Author:: cuoi

Field Summary

Fields

Modifier and Type Field Description

static String DEFAULT_CONNECTOR_NAME
Constructor Summary

Constructors

Constructor Description

OpflowConnector(Map<String,Object> kwargs)

Method Summary

Modifier and Type	Method	Description
`static Map<String,Boolean>`	`applyConnectors(Map<String,OpflowConnector> connectors, Function<OpflowConnector,Boolean> action)`
`void`	`close()`
`OpflowRpcAmqpMaster`	`getAmqpMaster()`
`OpflowRpcHttpMaster`	`getHttpMaster()`
`Map<String,OpflowRpcInvocationHandler>`	`getMappings()`
`OpflowPromMeasurer`	`getMeasurer()`
`OpflowPubsubHandler`	`getPublisher()`
`OpflowRpcChecker`	`getRpcChecker()`
`Map<String,Object>`	`getRpcInvocationCounter()`
`OpflowThroughput.Tuple`	`getSpeedMeter()`
`void`	`ping(String query)`
`<T> T`	`registerType(Class<T> type)`
`<T> T`	`registerType(Class<T> type, T bean)`
`void`	`resetRpcInvocationCounter()`
`void`	`serve()`
`<T> void`	`unregisterType(Class<T> type)`

Methods inherited from class java.lang.Object

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

Field Details
- DEFAULT_CONNECTOR_NAME
  
  public static final String DEFAULT_CONNECTOR_NAME
  
  See Also:
  
  Constant Field Values
Constructor Details
- OpflowConnector
  
  public OpflowConnector(Map<String,Object> kwargs) throws OpflowBootstrapException
  
  Throws:
  
  OpflowBootstrapException
Method Details
- getMeasurer
  
  public OpflowPromMeasurer getMeasurer()
- getSpeedMeter
  
  public OpflowThroughput.Tuple getSpeedMeter()
- getRpcChecker
  
  public OpflowRpcChecker getRpcChecker()
- getPublisher
  
  public OpflowPubsubHandler getPublisher()
- getAmqpMaster
  
  public OpflowRpcAmqpMaster getAmqpMaster()
- getHttpMaster
  
  public OpflowRpcHttpMaster getHttpMaster()
- getMappings
  
  public Map<String,OpflowRpcInvocationHandler> getMappings()
- serve
  
  public void serve()
- close
  
  public void close()
- ping
  
  public void ping(String query) throws Throwable
  
  Throws:
  
  Throwable
- registerType
  
  public <T> T registerType(Class<T> type)
- registerType
  
  public <T> T registerType(Class<T> type, T bean)
- unregisterType
  
  public <T> void unregisterType(Class<T> type)
- getRpcInvocationCounter
  
  public Map<String,Object> getRpcInvocationCounter()
- resetRpcInvocationCounter
  
  public void resetRpcInvocationCounter()
- applyConnectors
  
  public static Map<String,Boolean> applyConnectors(Map<String,OpflowConnector> connectors, Function<OpflowConnector,Boolean> action)