org.springframework.xd.reactor

Class AbstractReactorMessageHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.handler.AbstractMessageProducingHandler

org.springframework.xd.reactor.AbstractReactorMessageHandler

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, org.springframework.integration.context.Orderable, org.springframework.integration.core.MessageProducer, org.springframework.integration.support.context.NamedComponent, org.springframework.integration.support.management.ConfigurableMetricsAware<org.springframework.integration.support.management.AbstractMessageHandlerMetrics>, org.springframework.integration.support.management.IntegrationManagement, org.springframework.integration.support.management.IntegrationStatsManagement, org.springframework.integration.support.management.MessageHandlerMetrics, org.springframework.integration.support.management.TrackableComponent, org.springframework.messaging.MessageHandler

Direct Known Subclasses:

BroadcasterMessageHandler, MultipleBroadcasterMessageHandler

public abstract class AbstractReactorMessageHandler
extends org.springframework.integration.handler.AbstractMessageProducingHandler
implements org.springframework.beans.factory.DisposableBean

Abstract base class for Reactor based MessageHandlers.

Author:

Mark Pollack

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractReactorMessageHandler.ChannelForwardingSubscriber

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	logger
protected Processor	processor

Fields inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

messagingTemplate

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
AbstractReactorMessageHandler(Processor processor) Construct a new BroadcasterMessageHandler given the reactor based Processor to delegate processing to.

Method Summary

Methods

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.

Methods inherited from class org.springframework.integration.handler.AbstractMessageProducingHandler

getOutputChannel, onInit, produceOutput, sendOutputs, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

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

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.DisposableBean

destroy

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Field Detail

logger

protected final org.slf4j.Logger logger

processor

protected final Processor processor

Constructor Detail

AbstractReactorMessageHandler

public AbstractReactorMessageHandler(Processor processor)

Construct a new BroadcasterMessageHandler given the reactor based Processor to delegate processing to.

Parameters:

processor - The stream based reactor processor

Method Detail

setStopTimeout

public 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. Default is 5000 milliseconds

Parameters:

stopTimeoutInMillis - time to wait when shutting down the processor.

getStopTimeout

public int getStopTimeout()

Return the time to wait when shutting down the processor in millseconds

setRingBufferSize

public void setRingBufferSize(int ringBufferSize)

The size of the RingBuffer, must be a power of 2. Default is 8192.

Parameters:

ringBufferSize - size of the RingBuffer.

getRingBufferSize

public int getRingBufferSize()

Return the size of the RingBuffer

getEnvironment

public reactor.Environment getEnvironment()

Return the environment to use for stream processing operations.

getInputType

public java.lang.Class<?> getInputType()

Returns the input type of the stream that is to be processed

invokeProcessor

protected void invokeProcessor(org.springframework.messaging.Message<?> message,
                   reactor.core.processor.RingBufferProcessor<java.lang.Object> reactiveProcessorToUse)