public abstract class AbstractConsumer extends java.lang.Object implements IConsumer
Modifier and Type | Field and Description |
---|---|
protected com.rabbitmq.client.Channel |
channel |
protected com.rabbitmq.client.Connection |
con |
protected com.rabbitmq.client.DefaultConsumer |
consumer |
protected java.lang.String |
host |
protected java.lang.String |
queueName |
Constructor and Description |
---|
AbstractConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the Consumer Object
|
abstract void |
consume(byte[] data)
The method which gets the rabbitMQ bytes and can process them
|
void |
init(java.lang.String host,
java.lang.String queueName)
Will initialize the rabbitMQ messaging from one module to another.
|
protected com.rabbitmq.client.Channel channel
protected com.rabbitmq.client.Connection con
protected java.lang.String queueName
protected java.lang.String host
protected com.rabbitmq.client.DefaultConsumer consumer
public void init(java.lang.String host, java.lang.String queueName) throws IguanaException
init
in interface IConsumer
IguanaException
public abstract void consume(byte[] data)
data
-