Package com.swiftmq.impl.streams.processor

Class QueueMessageProcessor

java.lang.Object

MessageProcessor

com.swiftmq.impl.streams.processor.QueueMessageProcessor

public class QueueMessageProcessor
extends MessageProcessor

Constructor Summary

Constructors

Constructor	Description
QueueMessageProcessor(StreamContext ctx, Input input, QueueReceiver receiver, Selector selector)

Method Summary

Modifier and Type	Method	Description
void	deregister()
Input	getInput()
MessageImpl	getMessage()
QueuePullTransaction	getTransaction()
boolean	isValid()
void	processException(Exception e)
void	processMessage(MessageEntry messageEntry)
void	restart()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

QueueMessageProcessor

public QueueMessageProcessor(StreamContext ctx,
 Input input,
 QueueReceiver receiver,
 Selector selector)

Method Details

deregister

public void deregister()

restart

public void restart()
             throws Exception

Throws:

Exception

getTransaction

public QueuePullTransaction getTransaction()

getInput

public Input getInput()

getMessage

public MessageImpl getMessage()

processMessage

public void processMessage(MessageEntry messageEntry)

processException

public void processException(Exception e)

isValid

public boolean isValid()

toString

public String toString()