Package org.frankframework.pipes

Class PostboxRetrieverPipe

java.lang.Object
org.frankframework.core.TransactionAttributes
org.frankframework.pipes.AbstractPipe
org.frankframework.pipes.FixedForwardPipe
org.frankframework.pipes.PostboxRetrieverPipe
All Implemented Interfaces:
HasTransactionAttribute, IConfigurable, IConfigurationAware, IForwardTarget, INamedObject, IPipe, IScopeProvider, IWithParameters, EventThrowing, HasStatistics, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware
@Deprecated public class PostboxRetrieverPipe extends FixedForwardPipe
Deprecated.
Retrieves a message using an IPostboxListener. Note that most listeners allow you to specify a timeout. The timeout has the following meaning:
  • <0 = no wait
  • 0 = block until message available
  • >= 0 maximum wait in milliseconds
nested elementsdescription listenerspecification of postbox listener to retrieve messages from

Author:
John Dekker

  • Constructor Details

    • PostboxRetrieverPipe

      public PostboxRetrieverPipe()
      Deprecated.

  • Method Details

    • configure

      public void configure() throws ConfigurationException
      Deprecated.
      Description copied from class: FixedForwardPipe
      checks for correct configuration of forward
      Specified by:
      configure in interface IConfigurable
      Specified by:
      configure in interface IPipe
      Overrides:
      configure in class FixedForwardPipe
      Throws:
      ConfigurationException

    • getListener

      public IPostboxListener getListener()
      Deprecated.

    • setListener

      public void setListener(IPostboxListener listener)
      Deprecated.

    • start

      public void start() throws PipeStartException
      Deprecated.
      Description copied from interface: IPipe
      Perform necessary action to start the pipe. This method is executed after the IPipe.configure() method, for each start and stop command of the adapter.
      Specified by:
      start in interface IPipe
      Overrides:
      start in class AbstractPipe
      Throws:
      PipeStartException

    • stop

      public void stop()
      Deprecated.
      Description copied from interface: IPipe
      Perform necessary actions to stop the Pipe.
      For instance, closing JMS connections, DBMS connections etc.
      Specified by:
      stop in interface IPipe
      Overrides:
      stop in class AbstractPipe

    • doPipe

      public PipeRunResult doPipe(Message message, PipeLineSession session) throws PipeRunException
      Deprecated.
      Description copied from interface: IPipe
      This is where the action takes place. Pipes may only throw a PipeRunException, to be handled by the caller of this object. Implementations must either consume the message, or pass it on to the next Pipe in the PipeRunResult. If the result of the Pipe does not depend on the input, like for the FixedResultPipe, the Pipe can schedule the input to be closed at session exit, by calling Message.closeOnCloseOf(PipeLineSession, String) This allows the previous Pipe to release any resources (e.g. connections) that it might have kept open until the message was consumed. Doing so avoids connections leaking from pools, while it enables efficient streaming processing of data while it is being read from a stream.
      Throws:
      PipeRunException

    • getResultOnEmptyPostbox

      public String getResultOnEmptyPostbox()
      Deprecated.

    • setResultOnEmptyPostbox

      public void setResultOnEmptyPostbox(String string)
      Deprecated.
      result when no object is on postbox
      Default value
      empty postbox