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.Operator
static class	OpflowEngine.State

Field Summary

Fields

Modifier and Type	Field	Description
static String[]	PARAMETER_NAMES

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(OpflowListener listener, Map<String,Object> options)
protected void	finalize()
String	getApplicationId()
Boolean	getExchangeDurable()
String	getExchangeName()
String[]	getOtherKeys()
String	getRoutingKey()
void	produce(byte[] body, Map<String,Object> headers)
void	produce(byte[] body, Map<String,Object> headers, com.rabbitmq.client.AMQP.BasicProperties.Builder propBuilder)
void	produce(byte[] body, Map<String,Object> headers, com.rabbitmq.client.AMQP.BasicProperties.Builder propBuilder, Map<String,Object> override)
void	produce(byte[] body, Map<String,Object> headers, Map<String,Object> override)

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

Constructor Details

OpflowEngine

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

Throws:

OpflowBootstrapException

Method Details

getExchangeName

public String getExchangeName()

getExchangeDurable

public Boolean getExchangeDurable()

getRoutingKey

public String getRoutingKey()

getOtherKeys

public String[] getOtherKeys()

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.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.client.AMQP.BasicProperties.Builder propBuilder, Map<String,Object> override)

consume

public OpflowEngine.ConsumerInfo consume(OpflowListener 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

finalize

protected void finalize() throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable