org.aksw.iguana.commons.consumer

Class AbstractConsumer

java.lang.Object

org.aksw.iguana.commons.consumer.AbstractConsumer

All Implemented Interfaces:

IConsumer

Direct Known Subclasses:

DefaultConsumer, DefaultConsumer, DefaultConsumer, DefaultConsumer, SingularConsumer, TestConsumer

public abstract class AbstractConsumer
extends java.lang.Object
implements IConsumer

Abstract class which handles the rabbitMQ connection.
only the consume method needs to be implemented.

Author:

f.conrads

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
AbstractConsumer()

Method Summary

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.

Methods inherited from class java.lang.Object

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

Field Detail

channel

protected com.rabbitmq.client.Channel channel

con

protected com.rabbitmq.client.Connection con

queueName

protected java.lang.String queueName

host

protected java.lang.String host

consumer

protected com.rabbitmq.client.DefaultConsumer consumer

Constructor Detail

AbstractConsumer

public AbstractConsumer()

Method Detail

init

public void init(java.lang.String host,
                 java.lang.String queueName)
          throws IguanaException

Will initialize the rabbitMQ messaging from one module to another.

Specified by:

init in interface IConsumer

Throws:

IguanaException

consume

public abstract void consume(byte[] data)

The method which gets the rabbitMQ bytes and can process them

Parameters:

data -

close

public void close()

Description copied from interface: IConsumer

Closes the Consumer Object

Specified by:

close in interface IConsumer