Package com.devebot.opflow

Class OpflowRpcAmqpMaster

java.lang.Object

com.devebot.opflow.OpflowRpcAmqpMaster

All Implemented Interfaces:

AutoCloseable

public class OpflowRpcAmqpMaster
extends Object
implements AutoCloseable

Author:

drupalex

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	OpflowRpcAmqpMaster.State

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
OpflowRpcAmqpMaster.State	check()
void	close()
protected void	finalize()
int	getActiveRequestTotal()
String	getComponentId()
OpflowEngine	getEngine()
OpflowExecutor	getExecutor()
long	getExpiration()
int	getMaxWaitingRequests()
Boolean	getResponseQueueAutoDelete()
Boolean	getResponseQueueDurable()
Boolean	getResponseQueueExclusive()
String	getResponseQueueName()
OpflowRpcAmqpRequest	request(String routineSignature, byte[] body)
OpflowRpcAmqpRequest	request(String routineSignature, byte[] body, OpflowRpcParameter params)
OpflowRpcAmqpRequest	request(String routineSignature, byte[] body, OpflowRpcParameter params, OpflowRpcRoutingInfo routingInfo)
OpflowRpcAmqpRequest	request(String routineSignature, byte[] body, OpflowRpcRoutingInfo routingInfo)
OpflowRpcAmqpRequest	request(String routineSignature, String body)
OpflowRpcAmqpRequest	request(String routineSignature, String body, OpflowRpcParameter params)
OpflowRpcAmqpRequest	request(String routineSignature, String body, OpflowRpcRoutingInfo routingInfo)
void	reset()
void	resetCallbackQueueCounter()
void	serve()

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowRpcAmqpMaster

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

Throws:

OpflowBootstrapException

Method Details

request

public OpflowRpcAmqpRequest request(String routineSignature, String body)

request

public OpflowRpcAmqpRequest request(String routineSignature, String body, OpflowRpcParameter params)

request

public OpflowRpcAmqpRequest request(String routineSignature, String body, OpflowRpcRoutingInfo routingInfo)

request

public OpflowRpcAmqpRequest request(String routineSignature, byte[] body)

request

public OpflowRpcAmqpRequest request(String routineSignature, byte[] body, OpflowRpcParameter params)

request

public OpflowRpcAmqpRequest request(String routineSignature, byte[] body, OpflowRpcRoutingInfo routingInfo)

request

public OpflowRpcAmqpRequest request(String routineSignature, byte[] body, OpflowRpcParameter params, OpflowRpcRoutingInfo routingInfo)

getActiveRequestTotal

public int getActiveRequestTotal()

getMaxWaitingRequests

public int getMaxWaitingRequests()

resetCallbackQueueCounter

public void resetCallbackQueueCounter()

check

public OpflowRpcAmqpMaster.State check()

serve

public final void serve()

close

public void close()

Specified by:

close in interface AutoCloseable

reset

public void reset()

getEngine

public OpflowEngine getEngine()

getExecutor

public OpflowExecutor getExecutor()

getComponentId

public String getComponentId()

getExpiration

public long getExpiration()

getResponseQueueName

public String getResponseQueueName()

getResponseQueueAutoDelete

public Boolean getResponseQueueAutoDelete()

getResponseQueueDurable

public Boolean getResponseQueueDurable()

getResponseQueueExclusive

public Boolean getResponseQueueExclusive()

finalize

protected void finalize() throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable