Package com.devebot.opflow

Class OpflowRpcAmqpWorker

java.lang.Object

com.devebot.opflow.OpflowRpcAmqpWorker

All Implemented Interfaces:

AutoCloseable

public class OpflowRpcAmqpWorker
extends Object
implements AutoCloseable

Author:

drupalex

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	OpflowRpcAmqpWorker.Checker
static interface	OpflowRpcAmqpWorker.Listener
class	OpflowRpcAmqpWorker.Middleware
class	OpflowRpcAmqpWorker.State

Constructor Summary

Constructors

Constructor	Description
OpflowRpcAmqpWorker(Map<String,Object> params)

Method Summary

Modifier and Type	Method	Description
OpflowRpcAmqpWorker.State	check()
void	close()
protected void	finalize()
String	getComponentId()
OpflowEngine	getEngine()
OpflowExecutor	getExecutor()
Boolean	getIncomingQueueAutoDelete()
Boolean	getIncomingQueueDurable()
Boolean	getIncomingQueueExclusive()
String	getIncomingQueueName()
OpflowEngine.ConsumerInfo	process(OpflowRpcAmqpWorker.Checker checker, OpflowRpcAmqpWorker.Listener listener)
OpflowEngine.ConsumerInfo	process(OpflowRpcAmqpWorker.Listener listener)
OpflowEngine.ConsumerInfo	process(String[] routineSignatures, OpflowRpcAmqpWorker.Listener listener)
OpflowEngine.ConsumerInfo	process(String routineSignature, OpflowRpcAmqpWorker.Listener listener)
OpflowEngine.ConsumerInfo	process(Set<String> routineSignatures, OpflowRpcAmqpWorker.Listener listener)
void	setHttpAddress(String address)

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowRpcAmqpWorker

public OpflowRpcAmqpWorker(Map<String,Object> params) throws OpflowBootstrapException

Throws:

OpflowBootstrapException

Method Details

process

public OpflowEngine.ConsumerInfo process(OpflowRpcAmqpWorker.Listener listener)

process

public OpflowEngine.ConsumerInfo process(String routineSignature, OpflowRpcAmqpWorker.Listener listener)

process

public OpflowEngine.ConsumerInfo process(String[] routineSignatures, OpflowRpcAmqpWorker.Listener listener)

process

public OpflowEngine.ConsumerInfo process(Set<String> routineSignatures, OpflowRpcAmqpWorker.Listener listener)

process

public OpflowEngine.ConsumerInfo process(OpflowRpcAmqpWorker.Checker checker, OpflowRpcAmqpWorker.Listener listener)

check

public OpflowRpcAmqpWorker.State check()

close

public void close()

Specified by:

close in interface AutoCloseable

getEngine

public OpflowEngine getEngine()

getExecutor

public OpflowExecutor getExecutor()

getComponentId

public String getComponentId()

getIncomingQueueName

public String getIncomingQueueName()

getIncomingQueueDurable

public Boolean getIncomingQueueDurable()

getIncomingQueueExclusive

public Boolean getIncomingQueueExclusive()

getIncomingQueueAutoDelete

public Boolean getIncomingQueueAutoDelete()

setHttpAddress

public void setHttpAddress(String address)

finalize

protected void finalize() throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable