com.devebot.opflow

Class OpflowEngine

java.lang.Object

com.devebot.opflow.OpflowEngine

Direct Known Subclasses:

OpflowBroker

public class OpflowEngine
extends Object

Author:

drupalex

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
static String[]	PARAMETER_NAMES

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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)
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, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PARAMETER_NAMES

public static final String[] PARAMETER_NAMES

Constructor Detail

OpflowEngine

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

Throws:

OpflowBootstrapException

Method Detail

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.

Throws:

OpflowOperationException - if an error is encountered