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

Interface Input

All Known Subinterfaces:
DestinationInput
All Known Implementing Classes:
ManagementInput, QueueInput, QueueWireTapInput, TopicInput
public interface Input
Base interface for Inputs.
Author:
IIT Software GmbH, Muenster/Germany, (c) 2016, All Rights Reserved

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    Closes this Input.
    void
    collect(long interval)
    Internal use.
    Message
    current()
    Returns the current Message of this Input.
    Input
    current(Message current)
    Sets the current Message on this Input.
    void
    executeCallback()
    Internal use.
    String
    getName()
    Returns the name of this Input.
    void
    start()
    Starts this Input.

  • Method Details

    • getName

      String getName()
      Returns the name of this Input.
      Returns:
      Name

    • current

      Input current(Message current)
      Sets the current Message on this Input.
      Parameters:
      current - Message
      Returns:
      Input

    • current

      Message current()
      Returns the current Message of this Input.
      Returns:
      Message

    • executeCallback

      void executeCallback() throws Exception
      Internal use.
      Throws:
      Exception

    • collect

      void collect(long interval)
      Internal use.

    • start

      void start() throws Exception
      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.
      Throws:
      Exception

    • close

      void close()
      Closes this Input.