Package com.swiftmq.impl.amqp.amqp.v01_00_00

Class SourceMessageProcessor

java.lang.Object

MessageProcessor

com.swiftmq.impl.amqp.amqp.v01_00_00.SourceMessageProcessor

public class SourceMessageProcessor
extends MessageProcessor

Constructor Summary

Constructors

Constructor	Description
SourceMessageProcessor(SwiftletContext ctx, SourceLink sourceLink)

Method Summary

Modifier and Type	Method	Description
Exception	getException()
SourceLink	getSourceLink()
Delivery	getTransformedMessage()
Delivery[]	getTransformedMessages()
boolean	isValid()
void	processException(Exception exception)
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,
 SourceLink sourceLink)

Method Details

getSourceLink

public SourceLink getSourceLink()

processMessages

public void processMessages(int numberMessages)

processMessage

public void processMessage(MessageEntry messageEntry)

processException

public void processException(Exception exception)

getException

public Exception getException()

getTransformedMessage

public Delivery getTransformedMessage()
                               throws JMSException

Throws:

JMSException

getTransformedMessages

public Delivery[] getTransformedMessages()
                                  throws JMSException

Throws:

JMSException

setStopped

public void setStopped(boolean stopped)

isValid

public boolean isValid()

toString

public String toString()