Package com.swiftmq.impl.streams.comp.io
Interface DestinationInput
-
- All Superinterfaces:
Input
- All Known Implementing Classes:
QueueInput
,QueueWireTapInput
,TopicInput
public interface DestinationInput extends Input
Intermediate interface to separate JMS destination 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 java.lang.String
destinationName()
Returns the destinationNameDestinationInput
destinationName(java.lang.String destinationName)
Sets the destinationName if different from the name used in stream.create().input(name)QueueMessageProcessor
getMessageProcessor()
Internal use.java.lang.String
getSelector()
Returns the associated JMS Message SelectorDestinationInput
onInput(InputCallback callback)
Sets the onInput callback.DestinationInput
selector(java.lang.String selector)
Sets the JMS Message Selectorvoid
setMessageProcessor(QueueMessageProcessor messageProcessor)
Internal use.
-
-
-
Method Detail
-
getMessageProcessor
QueueMessageProcessor getMessageProcessor()
Internal use.
-
setMessageProcessor
void setMessageProcessor(QueueMessageProcessor messageProcessor)
Internal use.
-
getSelector
java.lang.String getSelector()
Returns the associated JMS Message Selector- Returns:
- JMS Message Selector
-
selector
DestinationInput selector(java.lang.String selector)
Sets the JMS Message Selector- Parameters:
selector
- JMS Message Selector- Returns:
- DestinationInput
-
onInput
DestinationInput onInput(InputCallback callback)
Sets the onInput callback.- Parameters:
callback
- callback- Returns:
- DestinationInput
-
destinationName
DestinationInput destinationName(java.lang.String destinationName)
Sets the destinationName if different from the name used in stream.create().input(name)- Parameters:
destinationName
- destinationName- Returns:
- DestinationInput
-
destinationName
java.lang.String destinationName()
Returns the destinationName- Returns:
- destinationName
-
-