Package com.devebot.opflow

Class OpflowExecutor

java.lang.Object

com.devebot.opflow.OpflowExecutor

public class OpflowExecutor
extends Object

Author:

drupalex

Constructor Summary

Constructors

Constructor	Description
OpflowExecutor(OpflowEngine engine)

Method Summary

Modifier and Type	Method	Description
void	assertQueue(String queueName)
void	assertQueue(String queueName, Boolean durable, Boolean exclusive, Boolean autoDelete)
void	assertQueue(String queueName, Boolean durable, Boolean exclusive, Boolean autoDelete, Map<String,Object> options)
void	bindExchange(String exchangeName, String[] bindingKeys, String queueName)
void	bindExchange(String exchangeName, String routingKey, String queueName)
int	countQueue(String queueName)
com.rabbitmq.nostro.client.AMQP.Exchange.DeclareOk	defineExchange(String exchangeName)
com.rabbitmq.nostro.client.AMQP.Exchange.DeclareOk	defineExchange(String exchangeName, String exchangeType)
com.rabbitmq.nostro.client.AMQP.Queue.DeclareOk	defineQueue(String queueName)
com.rabbitmq.nostro.client.AMQP.Queue.DeclareOk	defineQueue(String queueName, Boolean durable, Boolean exclusive, Boolean autoDelete)
com.rabbitmq.nostro.client.AMQP.Exchange.DeleteOk	deleteExchange(String exchangeName)
com.rabbitmq.nostro.client.AMQP.Queue.DeleteOk	deleteQueue(String queueName)
com.rabbitmq.nostro.client.AMQP.Queue.PurgeOk	purgeQueue(String queueName)

Methods inherited from class java.lang.Object

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

Constructor Details

OpflowExecutor

public OpflowExecutor(OpflowEngine engine)

Method Details

assertQueue

public void assertQueue(String queueName) throws OpflowBootstrapException

Throws:

OpflowBootstrapException

assertQueue

public void assertQueue(String queueName, Boolean durable, Boolean exclusive, Boolean autoDelete) throws OpflowBootstrapException

Throws:

OpflowBootstrapException

assertQueue

public void assertQueue(String queueName, Boolean durable, Boolean exclusive, Boolean autoDelete, Map<String,Object> options) throws OpflowBootstrapException

Throws:

OpflowBootstrapException

defineQueue

public com.rabbitmq.nostro.client.AMQP.Queue.DeclareOk defineQueue(String queueName)

defineQueue

public com.rabbitmq.nostro.client.AMQP.Queue.DeclareOk defineQueue(String queueName, Boolean durable, Boolean exclusive, Boolean autoDelete)

countQueue

public int countQueue(String queueName)

purgeQueue

public com.rabbitmq.nostro.client.AMQP.Queue.PurgeOk purgeQueue(String queueName)

deleteQueue

public com.rabbitmq.nostro.client.AMQP.Queue.DeleteOk deleteQueue(String queueName)

defineExchange

public com.rabbitmq.nostro.client.AMQP.Exchange.DeclareOk defineExchange(String exchangeName)

defineExchange

public com.rabbitmq.nostro.client.AMQP.Exchange.DeclareOk defineExchange(String exchangeName, String exchangeType)

deleteExchange

public com.rabbitmq.nostro.client.AMQP.Exchange.DeleteOk deleteExchange(String exchangeName)

bindExchange

public void bindExchange(String exchangeName, String routingKey, String queueName)

bindExchange

public void bindExchange(String exchangeName, String[] bindingKeys, String queueName)