Package com.devebot.opflow

Class OpflowEngine

java.lang.Object

com.devebot.opflow.OpflowEngine

All Implemented Interfaces:

AutoCloseable

public class OpflowEngine
extends Object
implements AutoCloseable

Author:

drupalex

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	OpflowEngine.ConsumerInfo
static interface	OpflowEngine.Listener
static class	OpflowEngine.Message
static interface	OpflowEngine.Operator
static class	OpflowEngine.State

Field Summary

Fields

Modifier and Type	Field	Description
static String[]	PARAMETER_NAMES
static String[]	SHARED_PARAMETERS

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
<T> T	acquireChannel(OpflowEngine.Operator listener)
void	cancelConsumer(OpflowEngine.ConsumerInfo consumerInfo)
OpflowEngine.State	check()
void	close()	Close this broker.
OpflowEngine.ConsumerInfo	consume(OpflowEngine.Listener listener, Map<String,Object> options)
protected void	finalize()
String	getApplicationId()
Boolean	getExchangeDurable()
String	getExchangeName()
String	getExchangeType()
String	getRoutingKey()
void	produce(byte[] body, Map<String,Object> headers)
void	produce(byte[] body, Map<String,Object> headers, com.rabbitmq.nostro.client.AMQP.BasicProperties.Builder propBuilder)
void	produce(byte[] body, Map<String,Object> headers, com.rabbitmq.nostro.client.AMQP.BasicProperties.Builder propBuilder, Map<String,Object> override, OpflowLogTracer reqTracer)
void	produce(byte[] body, Map<String,Object> headers, Map<String,Object> override)
void	setConsumingBlockedListener(com.rabbitmq.nostro.client.BlockedListener consumingBlockedListener)
void	setProducingBlockedListener(com.rabbitmq.nostro.client.BlockedListener producingBlockedListener)

Methods inherited from class java.lang.Object

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

Field Details

PARAMETER_NAMES

public static final String[] PARAMETER_NAMES

SHARED_PARAMETERS

public static final String[] SHARED_PARAMETERS

Constructor Details

OpflowEngine

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

Throws:

OpflowBootstrapException

Method Details

getExchangeName

public String getExchangeName()

getExchangeType

public String getExchangeType()

getExchangeDurable

public Boolean getExchangeDurable()

getRoutingKey

public String getRoutingKey()

getApplicationId

public String getApplicationId()

produce

public void produce(byte[] body, Map<String,Object> headers)

produce

public void produce(byte[] body, Map<String,Object> headers, com.rabbitmq.nostro.client.AMQP.BasicProperties.Builder propBuilder)

produce

public void produce(byte[] body, Map<String,Object> headers, Map<String,Object> override)

produce

public void produce(byte[] body, Map<String,Object> headers, com.rabbitmq.nostro.client.AMQP.BasicProperties.Builder propBuilder, Map<String,Object> override, OpflowLogTracer reqTracer)

consume

public OpflowEngine.ConsumerInfo consume(OpflowEngine.Listener listener, Map<String,Object> options)

acquireChannel

public <T> T acquireChannel(OpflowEngine.Operator listener) throws IOException, TimeoutException

Throws:

IOException

TimeoutException

cancelConsumer

public void cancelConsumer(OpflowEngine.ConsumerInfo consumerInfo)

check

public OpflowEngine.State check()

close

public void close()

Close this broker.

Specified by:

close in interface AutoCloseable

Throws:

OpflowOperationException - if an error is encountered

setProducingBlockedListener

public void setProducingBlockedListener(com.rabbitmq.nostro.client.BlockedListener producingBlockedListener)

setConsumingBlockedListener

public void setConsumingBlockedListener(com.rabbitmq.nostro.client.BlockedListener consumingBlockedListener)

finalize

protected void finalize() throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable