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.ChannelInterceptorListIntegrationManagement.ManagementOverridesinterceptors, metersEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
FluxMessageChannel() |
| Modifier and Type | Method and Description |
|---|---|
void |
destroy() |
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<? extends org.springframework.messaging.Message<?>> publisher) |
addInterceptor, addInterceptor, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, onInit, registerMetricsCaptor, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrackafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetIntegrationPatternTypegetManagedName, getManagedType, getThisAs, setManagedName, setManagedTypegetBeanName, getComponentNameprotected boolean doSend(org.springframework.messaging.Message<?> message,
long timeout)
AbstractMessageChanneldoSend in class AbstractMessageChannelmessage - 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<? extends org.springframework.messaging.Message<?>> publisher)
subscribeTo in interface ReactiveStreamsSubscribableChannelpublic void destroy()
destroy in interface org.springframework.beans.factory.DisposableBeandestroy in interface IntegrationManagementdestroy in class AbstractMessageChannel