Class POMessage
java.lang.Object
com.swiftmq.tools.pipeline.POObject
com.swiftmq.impl.streams.processor.po.POMessage
public class POMessage
extends com.swiftmq.tools.pipeline.POObject
-
Constructor Summary
ConstructorsConstructorDescriptionPOMessage(com.swiftmq.tools.concurrent.Semaphore semaphore, QueueMessageProcessor messageProcessor) -
Method Summary
Methods inherited from class com.swiftmq.tools.pipeline.POObject
getCallback, getException, getSemaphore, isSuccess, setException, setSuccess
-
Constructor Details
-
POMessage
public POMessage(com.swiftmq.tools.concurrent.Semaphore semaphore, QueueMessageProcessor messageProcessor)
-
-
Method Details
-
getMessageProcessor
-
accept
public void accept(com.swiftmq.tools.pipeline.POVisitor poVisitor) - Specified by:
acceptin classcom.swiftmq.tools.pipeline.POObject
-
toString
-