public abstract class AbstractReactorMessageHandler
extends org.springframework.integration.handler.AbstractMessageProducingHandler
implements org.springframework.beans.factory.DisposableBean
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractReactorMessageHandler.ChannelForwardingSubscriber |
Modifier and Type | Field and Description |
---|---|
protected org.slf4j.Logger |
logger |
protected Processor |
processor |
Constructor and Description |
---|
AbstractReactorMessageHandler(Processor processor)
Construct a new BroadcasterMessageHandler given the reactor based Processor to delegate
processing to.
|
Modifier and Type | Method and Description |
---|---|
reactor.Environment |
getEnvironment()
Return the environment to use for stream processing operations.
|
java.lang.Class<?> |
getInputType()
Returns the input type of the stream that is to be processed
|
int |
getRingBufferSize()
Return the size of the RingBuffer
|
int |
getStopTimeout()
Return the time to wait when shutting down the processor in millseconds
|
protected void |
invokeProcessor(org.springframework.messaging.Message<?> message,
reactor.core.processor.RingBufferProcessor<java.lang.Object> reactiveProcessorToUse) |
void |
setRingBufferSize(int ringBufferSize)
The size of the RingBuffer, must be a power of 2.
|
void |
setStopTimeout(int stopTimeoutInMillis)
Time in milliseconds to wait when shutting down the processor, waiting on a latch inside
the onComplete method of the subscriber.
|
getOutputChannel, onInit, produceOutput, sendOutputs, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput
configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, handleMessageInternal, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
protected final org.slf4j.Logger logger
protected final Processor processor
public AbstractReactorMessageHandler(Processor processor)
processor
- The stream based reactor processorpublic void setStopTimeout(int stopTimeoutInMillis)
stopTimeoutInMillis
- time to wait when shutting down the processor.public int getStopTimeout()
public void setRingBufferSize(int ringBufferSize)
ringBufferSize
- size of the RingBuffer.public int getRingBufferSize()
public reactor.Environment getEnvironment()
public java.lang.Class<?> getInputType()
protected void invokeProcessor(org.springframework.messaging.Message<?> message, reactor.core.processor.RingBufferProcessor<java.lang.Object> reactiveProcessorToUse)