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

Class TopicInput

java.lang.Object
com.swiftmq.impl.streams.comp.io.TopicInput
All Implemented Interfaces:
DestinationInput, Input
public class TopicInput extends Object implements DestinationInput
Consumes Messages from a Topic.
Author:
IIT Software GmbH, Muenster/Germany, (c) 2016, All Rights Reserved

  • Method Details

    • getName

      public String getName()
      Description copied from interface: Input
      Returns the name of this Input.
      Specified by:
      getName in interface Input
      Returns:
      Name

    • setName

      public void setName(String name)

    • getSelector

      public String getSelector()
      Description copied from interface: DestinationInput
      Returns the associated JMS Message Selector
      Specified by:
      getSelector in interface DestinationInput
      Returns:
      JMS Message Selector

    • getMessageProcessor

      public QueueMessageProcessor getMessageProcessor()
      Description copied from interface: DestinationInput
      Internal use.
      Specified by:
      getMessageProcessor in interface DestinationInput

    • setMessageProcessor

      public void setMessageProcessor(QueueMessageProcessor messageProcessor)
      Description copied from interface: DestinationInput
      Internal use.
      Specified by:
      setMessageProcessor in interface DestinationInput

    • destinationName

      public DestinationInput destinationName(String destinationName)
      Description copied from interface: DestinationInput
      Sets the destinationName if different from the name used in stream.create().input(name)
      Specified by:
      destinationName in interface DestinationInput
      Parameters:
      destinationName - destinationName
      Returns:
      DestinationInput

    • destinationName

      public String destinationName()
      Description copied from interface: DestinationInput
      Returns the destinationName
      Specified by:
      destinationName in interface DestinationInput
      Returns:
      destinationName

    • selector

      public DestinationInput selector(String selector)
      Description copied from interface: DestinationInput
      Sets the JMS Message Selector
      Specified by:
      selector in interface DestinationInput
      Parameters:
      selector - JMS Message Selector
      Returns:
      DestinationInput

    • current

      public Input current(Message current)
      Description copied from interface: Input
      Sets the current Message on this Input.
      Specified by:
      current in interface Input
      Parameters:
      current - Message
      Returns:
      Input

    • current

      public Message current()
      Description copied from interface: Input
      Returns the current Message of this Input.
      Specified by:
      current in interface Input
      Returns:
      Message

    • onInput

      public DestinationInput onInput(InputCallback callback)
      Description copied from interface: DestinationInput
      Sets the onInput callback.
      Specified by:
      onInput in interface DestinationInput
      Parameters:
      callback - callback
      Returns:
      DestinationInput

    • executeCallback

      public void executeCallback() throws Exception
      Description copied from interface: Input
      Internal use.
      Specified by:
      executeCallback in interface Input
      Throws:
      Exception

    • isDurable

      public boolean isDurable()
      Internal use.

    • getClientId

      public String getClientId()
      Internal use.

    • getDurableName

      public String getDurableName()
      Internal use.

    • getSubscriberId

      public int getSubscriberId()
      Internal use.

    • setSubscriberId

      public void setSubscriberId(int subscriberId)
      Internal use.

    • getQueueName

      public String getQueueName()
      Internal use.

    • setQueueName

      public void setQueueName(String queueName)
      Internal use.

    • durable

      public TopicInput durable()
      Marks this TopicInput as durable.
      Returns:
      TopicInput

    • clientId

      public TopicInput clientId(String clientId)
      Sets the client id for a durable subscriber.
      Parameters:
      clientId - client id
      Returns:
      TopicInput

    • durableName

      public TopicInput durableName(String durableName)
      Sets the durable name for a durable subscriber.
      Parameters:
      durableName - durable name
      Returns:
      TopicInput

    • collect

      public void collect(long interval)
      Description copied from interface: Input
      Internal use.
      Specified by:
      collect in interface Input

    • start

      public void start() throws Exception
      Description copied from interface: Input
      Starts this Input. This method is called automatically if an Input is created outside a callback. If it is created inside, it must be called explicitly.
      Specified by:
      start in interface Input
      Throws:
      Exception

    • close

      public void close()
      Description copied from interface: Input
      Closes this Input.
      Specified by:
      close in interface Input

    • toString

      public String toString()
      Overrides:
      toString in class Object