public class ReactiveChannel extends AbstractMessageChannel implements org.reactivestreams.Publisher<Message<?>>, ReactiveSubscribableChannel
AbstractMessageChannel.ChannelInterceptorListinterceptorsEXPRESSION_PARSER, loggerINDEFINITE_TIMEOUT| Constructor and Description |
|---|
ReactiveChannel() |
ReactiveChannel(org.reactivestreams.Processor<Message<?>,Message<?>> processor) |
| 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) |
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, setStatsEnabledafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNameprotected boolean doSend(Message<?> message, long timeout)
AbstractMessageChanneldoSend in class AbstractMessageChannelmessage - The message.timeout - The timeout.public void subscribe(org.reactivestreams.Subscriber<? super Message<?>> subscriber)
subscribe in interface org.reactivestreams.Publisher<Message<?>>public void subscribeTo(org.reactivestreams.Publisher<Message<?>> publisher)
subscribeTo in interface ReactiveSubscribableChannel