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 Details

    • POMessage

      public POMessage(com.swiftmq.tools.concurrent.Semaphore semaphore, QueueMessageProcessor messageProcessor)
  • Method Details

    • getMessageProcessor

      public QueueMessageProcessor getMessageProcessor()
    • 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