Class QueueInput

  • All Implemented Interfaces:
    DestinationInput, Input

    public class QueueInput
    extends java.lang.Object
    implements DestinationInput
    Consumes Messages from a Queue.
    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
      • 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
      • 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
      • 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
      • 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
      • 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