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(OpflowBroker engine)

Method Summary

Modifier and Type	Method and Description
void	assertQueue(String queueName)
com.rabbitmq.client.AMQP.Queue.DeclareOk	checkQueue(String queueName)
int	countQueue(String queueName)
void	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(OpflowBroker engine)

Method Detail

assertQueue

public void assertQueue(String queueName)
                 throws OpflowConstructorException

Throws:

OpflowConstructorException

checkQueue

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

countQueue

public int countQueue(String queueName)

purgeQueue

public void purgeQueue(String queueName)