org.springframework.integration.channel

Class ReactiveChannel

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.channel.AbstractMessageChannel

org.springframework.integration.channel.ReactiveChannel

All Implemented Interfaces:

org.reactivestreams.Publisher<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, ChannelInterceptorAware, ReactiveSubscribableChannel, ExpressionCapable, NamedComponent, ConfigurableMetricsAware<AbstractMessageChannelMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageChannelMetrics, TrackableComponent, MessageChannel

public class ReactiveChannel
extends AbstractMessageChannel
implements org.reactivestreams.Publisher<Message<?>>, ReactiveSubscribableChannel

Since:

5.0

Author:

Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.channel.AbstractMessageChannel

AbstractMessageChannel.ChannelInterceptorList

Field Summary

Fields inherited from class org.springframework.integration.channel.AbstractMessageChannel

interceptors

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

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
ReactiveChannel()
ReactiveChannel(org.reactivestreams.Processor<Message<?>,Message<?>> processor)

Method Summary

Modifier and Type	Method and Description
protected boolean	doSend(Message<?> message, long timeout) Subclasses must implement this method.
void	subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)
void	subscribeTo(org.reactivestreams.Publisher<Message<?>> publisher)

Methods inherited from class org.springframework.integration.channel.AbstractMessageChannel

addInterceptor, addInterceptor, configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMinSendDuration, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, removeInterceptor, removeInterceptor, reset, send, send, setCountsEnabled, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrack, setStatsEnabled

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

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, 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.integration.support.context.NamedComponent

getComponentName

Constructor Detail

ReactiveChannel

public ReactiveChannel()

ReactiveChannel

public ReactiveChannel(org.reactivestreams.Processor<Message<?>,Message<?>> processor)

Method Detail

doSend

protected boolean doSend(Message<?> message,
                         long timeout)

Description copied from class: AbstractMessageChannel

Subclasses must implement this method. A non-negative timeout indicates how long to wait if the channel is at capacity (if the value is 0, it must return immediately with or without success). A negative timeout value indicates that the method should block until either the message is accepted or the blocking thread is interrupted.

Specified by:

doSend in class AbstractMessageChannel

Parameters:

message - The message.

timeout - The timeout.

Returns:

true if the send was successful.

subscribe

public void subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)

Specified by:

subscribe in interface org.reactivestreams.Publisher<Message<?>>

subscribeTo

public void subscribeTo(org.reactivestreams.Publisher<Message<?>> publisher)

Specified by:

subscribeTo in interface ReactiveSubscribableChannel