Class TopicInput

  • All Implemented Interfaces:
    DestinationInput, Input

    public class TopicInput
    extends java.lang.Object
    implements DestinationInput
    Consumes Messages from a Topic.
    Author:
    IIT Software GmbH, Muenster/Germany, (c) 2016, All Rights Reserved
    • Method Detail

      • getName

        public java.lang.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​(java.lang.String name)
      • getSelector

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

        public DestinationInput destinationName​(java.lang.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
      • selector

        public DestinationInput selector​(java.lang.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
      • executeCallback

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

        public boolean isDurable()
        Internal use.
      • getClientId

        public java.lang.String getClientId()
        Internal use.
      • getDurableName

        public java.lang.String getDurableName()
        Internal use.
      • getSubscriberId

        public int getSubscriberId()
        Internal use.
      • setSubscriberId

        public void setSubscriberId​(int subscriberId)
        Internal use.
      • getQueueName

        public java.lang.String getQueueName()
        Internal use.
      • setQueueName

        public void setQueueName​(java.lang.String queueName)
        Internal use.
      • durable

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

        public TopicInput clientId​(java.lang.String clientId)
        Sets the client id for a durable subscriber.
        Parameters:
        clientId - client id
        Returns:
        TopicInput
      • durableName

        public TopicInput durableName​(java.lang.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 java.lang.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:
        java.lang.Exception
      • close

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

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object