OpflowRpcWorker (opflow-core 0.1.28 API)

java.lang.Object

com.devebot.opflow.OpflowRpcWorker

All Implemented Interfaces:: AutoCloseable

public class OpflowRpcWorker
extends Object
implements AutoCloseable

Author:: drupalex

Nested Class Summary

Nested Classes

Modifier and Type Class Description

static interface OpflowRpcWorker.Checker

class OpflowRpcWorker.Middleware

class OpflowRpcWorker.State
Constructor Summary

Constructors

Constructor Description

OpflowRpcWorker(Map<String,Object> params)

Method Summary

Modifier and Type	Method	Description
`OpflowRpcWorker.State`	`check()`
`void`	`close()`
`protected void`	`finalize()`
`String`	`getCallbackName()`
`String`	`getDispatchName()`
`OpflowEngine`	`getEngine()`
`OpflowExecutor`	`getExecutor()`
`String`	`getIntanceId()`
`OpflowEngine.ConsumerInfo`	`process(OpflowRpcListener listener)`
`OpflowEngine.ConsumerInfo`	`process(OpflowRpcWorker.Checker checker, OpflowRpcListener listener)`
`OpflowEngine.ConsumerInfo`	`process(String[] routineIds, OpflowRpcListener listener)`
`OpflowEngine.ConsumerInfo`	`process(String routineId, OpflowRpcListener listener)`
`OpflowEngine.ConsumerInfo`	`process(Set<String> routineIds, OpflowRpcListener listener)`

Methods inherited from class java.lang.Object

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

Constructor Details
- OpflowRpcWorker
  
  public OpflowRpcWorker(Map<String,Object> params) throws OpflowBootstrapException
  
  Throws:
  
  OpflowBootstrapException
Method Details
- process
  
  public OpflowEngine.ConsumerInfo process(OpflowRpcListener listener)
- process
  
  public OpflowEngine.ConsumerInfo process(String routineId, OpflowRpcListener listener)
- process
  
  public OpflowEngine.ConsumerInfo process(String[] routineIds, OpflowRpcListener listener)
- process
  
  public OpflowEngine.ConsumerInfo process(Set<String> routineIds, OpflowRpcListener listener)
- process
  
  public OpflowEngine.ConsumerInfo process(OpflowRpcWorker.Checker checker, OpflowRpcListener listener)
- check
  
  public OpflowRpcWorker.State check()
- close
  
  public void close()
  
  Specified by:
  
  close in interface AutoCloseable
- getExecutor
  
  public OpflowExecutor getExecutor()
- getEngine
  
  public OpflowEngine getEngine()
- getIntanceId
  
  public String getIntanceId()
- getDispatchName
  
  public String getDispatchName()
- getCallbackName
  
  public String getCallbackName()
- finalize
  
  protected void finalize() throws Throwable
  
  Overrides:
  
  finalize in class Object
  
  Throws:
  
  Throwable