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

Class SourceMessageProcessor

java.lang.Object

MessageProcessor

com.swiftmq.impl.amqp.amqp.v00_09_01.SourceMessageProcessor

public class SourceMessageProcessor
extends MessageProcessor

Constructor Summary

Constructors

Constructor	Description
SourceMessageProcessor(SwiftletContext ctx, Consumer consumer)

Method Summary

Modifier and Type	Method	Description
Consumer	getConsumer()
Exception	getException()
Delivery[]	getTransformedMessages()
boolean	isValid()
void	processException(Exception e)
void	processMessage(MessageEntry messageEntry)
void	processMessages(int numberMessages)
void	setStopped(boolean stopped)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

SourceMessageProcessor

public SourceMessageProcessor(SwiftletContext ctx,
 Consumer consumer)

Method Details

processMessages

public void processMessages(int numberMessages)

processMessage

public void processMessage(MessageEntry messageEntry)

processException

public void processException(Exception e)

getException

public Exception getException()

getConsumer

public Consumer getConsumer()

getTransformedMessages

public Delivery[] getTransformedMessages()
                                  throws Exception

Throws:

Exception

setStopped

public void setStopped(boolean stopped)

isValid

public boolean isValid()

toString

public String toString()