public interface ReactiveProcessor extends Function<org.reactivestreams.Publisher<CoreEvent>,org.reactivestreams.Publisher<CoreEvent>>
CoreEvent
's using a functional approach based on
Reactive Streams where CoreEvent
processing is defined via stream
functions.Modifier and Type | Interface and Description |
---|---|
static class |
ReactiveProcessor.ProcessingType
Defines the type of processing that the processor will be doing.
|
Modifier and Type | Method and Description |
---|---|
default ReactiveProcessor.ProcessingType |
getProcessingType()
In order for Mule to determine the best way to execute different processors based on the chosen
ProcessingStrategy it
needs to know the type of work the message processor will be performing and if it is ReactiveProcessor.ProcessingType.BLOCKING ,
ReactiveProcessor.ProcessingType.CPU_INTENSIVE intensive or neither (ReactiveProcessor.ProcessingType.CPU_LITE ). |
default ReactiveProcessor.ProcessingType getProcessingType()
ProcessingStrategy
it
needs to know the type of work the message processor will be performing and if it is ReactiveProcessor.ProcessingType.BLOCKING
,
ReactiveProcessor.ProcessingType.CPU_INTENSIVE
intensive or neither (ReactiveProcessor.ProcessingType.CPU_LITE
).
This method must return the same value for the same processor every time.
Copyright © 2018. All rights reserved.