Package com.swiftmq.impl.streams.comp.io

Interface DestinationInput

All Superinterfaces:
Input
All Known Implementing Classes:
QueueInput, QueueWireTapInput, TopicInput
public interface DestinationInput extends Input
Intermediate interface to separate JMS destination inputs.
Author:
IIT Software GmbH, Muenster/Germany, (c) 2016, All Rights Reserved

  • Method Details

    • getMessageProcessor

      QueueMessageProcessor getMessageProcessor()
      Internal use.

    • setMessageProcessor

      void setMessageProcessor(QueueMessageProcessor messageProcessor)
      Internal use.

    • getSelector

      String getSelector()
      Returns the associated JMS Message Selector
      Returns:
      JMS Message Selector

    • selector

      DestinationInput selector(String selector)
      Sets the JMS Message Selector
      Parameters:
      selector - JMS Message Selector
      Returns:
      DestinationInput

    • onInput

      DestinationInput onInput(InputCallback callback)
      Sets the onInput callback.
      Parameters:
      callback - callback
      Returns:
      DestinationInput

    • destinationName

      DestinationInput destinationName(String destinationName)
      Sets the destinationName if different from the name used in stream.create().input(name)
      Parameters:
      destinationName - destinationName
      Returns:
      DestinationInput

    • destinationName

      String destinationName()
      Returns the destinationName
      Returns:
      destinationName