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
All Methods Instance Methods Abstract Methods 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.java.lang.String
getName()
Returns the name of this Input.void
start()
Starts this Input.
-
-
-
Method Detail
-
getName
java.lang.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 java.lang.Exception
Internal use.- Throws:
java.lang.Exception
-
collect
void collect(long interval)
Internal use.
-
start
void start() throws java.lang.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:
java.lang.Exception
-
close
void close()
Closes this Input.
-
-