ReactiveProcessor.ProcessingType
Constructor and Description |
---|
QueueReaderMessageProcessor(Registry registry,
String queueName,
Long timeout)
Creates a queue reader
|
Modifier and Type | Method and Description |
---|---|
CoreEvent |
process(CoreEvent event)
Invokes the MessageProcessor.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getProcessingType
public QueueReaderMessageProcessor(Registry registry, String queueName, Long timeout)
registry
- application's mule context. Not null.queueName
- name of the queue to use. Non emptytimeout
- number of milliseconds to wait for an available event. Non negative. Null means no timeout required.public CoreEvent process(CoreEvent event) throws MuleException
Processor
process
in interface Processor
event
- MuleEvent to be processedMuleException
Copyright © 2018. All rights reserved.