Uses of Interface
com.swiftmq.impl.streams.comp.io.DestinationInput
-
Uses of DestinationInput in com.swiftmq.impl.streams.comp.io
Modifier and TypeClassDescriptionclass
Consumes Messages from a Queue.class
Creates or re-uses a named WireTap on a Queue and adds a subscriber to it.class
Consumes Messages from a Topic.Modifier and TypeMethodDescriptionDestinationInput.destinationName
(String destinationName) Sets the destinationName if different from the name used in stream.create().input(name)QueueInput.destinationName
(String destinationName) QueueWireTapInput.destinationName
(String destinationName) TopicInput.destinationName
(String destinationName) DestinationInput.onInput
(InputCallback callback) Sets the onInput callback.QueueInput.onInput
(InputCallback callback) QueueWireTapInput.onInput
(InputCallback callback) TopicInput.onInput
(InputCallback callback) Sets the JMS Message Selector