com.devebot.opflow

Class OpflowExecutor

java.lang.Object

com.devebot.opflow.OpflowExecutor

public class OpflowExecutor
extends Object

Author:

drupalex

Constructor Summary

Constructors

Constructor and Description
OpflowExecutor(OpflowEngine engine)

Method Summary

Modifier and Type	Method and Description
void	assertQueue(String queueName)
int	countQueue(String queueName)
com.rabbitmq.client.AMQP.Exchange.DeclareOk	defineExchange(String exchangeName, String exchangeType)
com.rabbitmq.client.AMQP.Queue.DeclareOk	defineQueue(String queueName)
com.rabbitmq.client.AMQP.Exchange.DeleteOk	deleteExchange(String exchangeName)
com.rabbitmq.client.AMQP.Queue.DeleteOk	deleteQueue(String queueName)
com.rabbitmq.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 Detail

OpflowExecutor

public OpflowExecutor(OpflowEngine engine)

Method Detail

assertQueue

public void assertQueue(String queueName)
                 throws OpflowBootstrapException

Throws:

OpflowBootstrapException

countQueue

public int countQueue(String queueName)

defineQueue

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

purgeQueue

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

deleteQueue

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

defineExchange

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

deleteExchange

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