Class PostboxRetrieverPipe

All Implemented Interfaces:
HasTransactionAttribute, IConfigurable, IConfigurationAware, IForwardTarget, INamedObject, IPipe, IScopeProvider, IWithParameters, EventThrowing, HasStatistics, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

@Deprecated(forRemoval=true, since="7.7.0") public class PostboxRetrieverPipe extends FixedForwardPipe
Deprecated, for removal: This API element is subject to removal in a future version.
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, for removal: This API element is subject to removal in a future version.
  • Method Details

    • configure

      public void configure() throws ConfigurationException
      Deprecated, for removal: This API element is subject to removal in a future version.
      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, for removal: This API element is subject to removal in a future version.
    • setListener

      public void setListener(IPostboxListener listener)
      Deprecated, for removal: This API element is subject to removal in a future version.
    • start

      public void start() throws PipeStartException
      Deprecated, for removal: This API element is subject to removal in a future version.
      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, for removal: This API element is subject to removal in a future version.
      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, for removal: This API element is subject to removal in a future version.
      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, for removal: This API element is subject to removal in a future version.
    • setResultOnEmptyPostbox

      public void setResultOnEmptyPostbox(String string)
      Deprecated, for removal: This API element is subject to removal in a future version.
      result when no object is on postbox
      Default value
      empty postbox