public class FluxMessageChannel extends AbstractMessageChannel implements org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>, ReactiveStreamsSubscribableChannel
AbstractMessageChannel
implementation for the
Reactive Streams Publisher
based on the Project Reactor Flux
.AbstractMessageChannel.ChannelInterceptorList
IntegrationManagement.ManagementOverrides
interceptors
EXPRESSION_PARSER, logger
Constructor and Description |
---|
FluxMessageChannel() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
doSend(org.springframework.messaging.Message<?> message,
long timeout)
Subclasses must implement this method.
|
void |
subscribe(org.reactivestreams.Subscriber<? super org.springframework.messaging.Message<?>> subscriber) |
void |
subscribeTo(org.reactivestreams.Publisher<org.springframework.messaging.Message<?>> publisher) |
addInterceptor, addInterceptor, configureMetrics, getChannelInterceptors, getComponentType, getErrorRate, getFullChannelName, getInterceptors, getMaxSendDuration, getMeanErrorRate, getMeanErrorRatio, getMeanSendDuration, getMeanSendRate, getMetrics, getMinSendDuration, getOverrides, getSendCount, getSendCountLong, getSendDuration, getSendErrorCount, getSendErrorCountLong, getSendRate, getStandardDeviationSendDuration, getTimeSinceLastSend, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, removeInterceptor, removeInterceptor, reset, send, send, setCountsEnabled, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
protected boolean doSend(org.springframework.messaging.Message<?> message, long timeout)
AbstractMessageChannel
doSend
in class AbstractMessageChannel
message
- The message.timeout
- The timeout.public void subscribe(org.reactivestreams.Subscriber<? super org.springframework.messaging.Message<?>> subscriber)
subscribe
in interface org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>
public void subscribeTo(org.reactivestreams.Publisher<org.springframework.messaging.Message<?>> publisher)
subscribeTo
in interface ReactiveStreamsSubscribableChannel