Package com.devebot.opflow

Class OpflowRpcHttpWorker

java.lang.Object

com.devebot.opflow.OpflowRpcHttpWorker

public class OpflowRpcHttpWorker
extends Object

Author:

acegik

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	OpflowRpcHttpWorker.Listener
static interface	OpflowRpcHttpWorker.Matcher
class	OpflowRpcHttpWorker.Middleware
static class	OpflowRpcHttpWorker.Output
static interface	OpflowRpcHttpWorker.Reporter

Constructor Summary

Constructors

Constructor	Description
OpflowRpcHttpWorker(Map<String,Object> kwargs)

Method Summary

Modifier and Type	Method	Description
protected void	assertSystemShutdownHook()
void	close()
String	getAddress()
String	getComponentId()
String	getHost()
String	getHostname()
Integer	getPort()
OpflowRpcHttpWorker.Reporter	process(OpflowRpcHttpWorker.Listener listener)
OpflowRpcHttpWorker.Reporter	process(OpflowRpcHttpWorker.Matcher matcher, OpflowRpcHttpWorker.Listener listener)
OpflowRpcHttpWorker.Reporter	process(String routineSignature, OpflowRpcHttpWorker.Listener listener)
OpflowRpcHttpWorker.Reporter	process(Set<String> routineSignatures, OpflowRpcHttpWorker.Listener listener)
void	serve()

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowRpcHttpWorker

public OpflowRpcHttpWorker(Map<String,Object> kwargs) throws OpflowBootstrapException

Throws:

OpflowBootstrapException

Method Details

getComponentId

public String getComponentId()

getHost

public String getHost()

getHostname

public String getHostname()

getPort

public Integer getPort()

getAddress

public String getAddress()

process

public OpflowRpcHttpWorker.Reporter process(OpflowRpcHttpWorker.Listener listener)

process

public OpflowRpcHttpWorker.Reporter process(String routineSignature, OpflowRpcHttpWorker.Listener listener)

process

public OpflowRpcHttpWorker.Reporter process(Set<String> routineSignatures, OpflowRpcHttpWorker.Listener listener)

process

public OpflowRpcHttpWorker.Reporter process(OpflowRpcHttpWorker.Matcher matcher, OpflowRpcHttpWorker.Listener listener)

serve

public void serve()

close

public void close()

assertSystemShutdownHook

protected void assertSystemShutdownHook()