Package com.swiftmq.impl.amqp.amqp.v00_09_01

Class Consumer

java.lang.Object

com.swiftmq.impl.amqp.amqp.v00_09_01.Consumer

public class Consumer
extends Object

Constructor Summary

Constructors

Constructor	Description
Consumer(SwiftletContext ctx, ChannelHandler channelHandler, String consumerTag, String originalQueueName, String queueName, boolean noAck, boolean noLocal)

Method Summary

Modifier and Type	Method	Description
void	ack(MessageIndex messageIndex)
void	close()
ChannelHandler	getChannelHandler()
String	getConsumerTag()
String	getOriginalQueueName()
String	getQueueName()
boolean	isClosed()
boolean	isNoAck()
boolean	isNoLocal()
void	reject(MessageIndex messageIndex)
void	startMessageProcessor()
void	startMessageProcessor(SourceMessageProcessor messageProcessor)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

Consumer

public Consumer(SwiftletContext ctx,
 ChannelHandler channelHandler,
 String consumerTag,
 String originalQueueName,
 String queueName,
 boolean noAck,
 boolean noLocal)
         throws Exception

Throws:

Exception

Method Details

getChannelHandler

public ChannelHandler getChannelHandler()

getConsumerTag

public String getConsumerTag()

getOriginalQueueName

public String getOriginalQueueName()

getQueueName

public String getQueueName()

isNoAck

public boolean isNoAck()

isNoLocal

public boolean isNoLocal()

isClosed

public boolean isClosed()

startMessageProcessor

public void startMessageProcessor()
                           throws QueueException

Throws:

QueueException

startMessageProcessor

public void startMessageProcessor(SourceMessageProcessor messageProcessor)
                           throws QueueException

Throws:

QueueException

ack

public void ack(MessageIndex messageIndex)
         throws Exception

Throws:

Exception

reject

public void reject(MessageIndex messageIndex)
            throws Exception

Throws:

Exception

close

public void close()

toString

public String toString()

Overrides:

toString in class Object