Uses of Class
com.swiftmq.impl.streams.processor.QueueMessageProcessor
-
Uses of QueueMessageProcessor in com.swiftmq.impl.streams.comp.io
Modifier and TypeMethodDescriptionDestinationInput.getMessageProcessor()
Internal use.QueueInput.getMessageProcessor()
QueueWireTapInput.getMessageProcessor()
TopicInput.getMessageProcessor()
Modifier and TypeMethodDescriptionvoid
DestinationInput.setMessageProcessor
(QueueMessageProcessor messageProcessor) Internal use.void
QueueInput.setMessageProcessor
(QueueMessageProcessor messageProcessor) void
QueueWireTapInput.setMessageProcessor
(QueueMessageProcessor messageProcessor) void
TopicInput.setMessageProcessor
(QueueMessageProcessor messageProcessor) -
Uses of QueueMessageProcessor in com.swiftmq.impl.streams.processor.po
ModifierConstructorDescriptionPOMessage
(Semaphore semaphore, QueueMessageProcessor messageProcessor)