Class POWireTapMessage

java.lang.Object

com.swiftmq.tools.pipeline.POObject

com.swiftmq.impl.streams.processor.po.POWireTapMessage

public class POWireTapMessage
extends com.swiftmq.tools.pipeline.POObject

Constructor Summary

Constructors

Constructor	Description
POWireTapMessage(com.swiftmq.tools.concurrent.Semaphore semaphore, QueueWireTapInput wiretapInput)

Method Summary

Modifier and Type	Method	Description
void	accept(com.swiftmq.tools.pipeline.POVisitor poVisitor)
Message	getMessage()
QueueWireTapInput	getWireTapInput()
String	toString()

Methods inherited from class com.swiftmq.tools.pipeline.POObject

getCallback, getException, getSemaphore, isSuccess, setException, setSuccess

Methods inherited from class Object

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

Constructor Details

POWireTapMessage

public POWireTapMessage(com.swiftmq.tools.concurrent.Semaphore semaphore,
 QueueWireTapInput wiretapInput)

Method Details

getWireTapInput

public QueueWireTapInput getWireTapInput()

getMessage

public Message getMessage()

accept

public void accept(com.swiftmq.tools.pipeline.POVisitor poVisitor)

Specified by:

accept in class com.swiftmq.tools.pipeline.POObject

toString

public String toString()

Overrides:

toString in class Object