Class FluxMessageChannel
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.channel.FluxMessageChannel
- All Implemented Interfaces:
org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>,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,ReactiveStreamsSubscribableChannel,ExpressionCapable,IntegrationPattern,NamedComponent,IntegrationManagement,TrackableComponent,org.springframework.messaging.MessageChannel,org.springframework.messaging.support.InterceptableChannel
public class FluxMessageChannel extends AbstractMessageChannel implements org.reactivestreams.Publisher<org.springframework.messaging.Message<?>>, ReactiveStreamsSubscribableChannel
The
AbstractMessageChannel implementation for the
Reactive Streams Publisher based on the Project Reactor Flux.- Since:
- 5.0
-
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.integration.channel.AbstractMessageChannel
AbstractMessageChannel.ChannelInterceptorListNested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement
IntegrationManagement.ManagementOverrides -
Field Summary
Fields inherited from class org.springframework.integration.channel.AbstractMessageChannel
interceptors, metersFields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME -
Constructor Summary
Constructors Constructor Description FluxMessageChannel() -
Method Summary
Modifier and Type Method Description voiddestroy()protected booleandoSend(org.springframework.messaging.Message<?> message, long timeout)Subclasses must implement this method.voidsubscribe(org.reactivestreams.Subscriber<? super org.springframework.messaging.Message<?>> subscriber)voidsubscribeTo(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>> publisher)Methods inherited from class org.springframework.integration.channel.AbstractMessageChannel
addInterceptor, addInterceptor, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, onInit, registerMetricsCaptor, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrackMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, 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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getManagedName, getManagedType, getThisAs, setManagedName, setManagedTypeMethods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentNameMethods inherited from interface org.springframework.integration.channel.ReactiveStreamsSubscribableChannel
getIntegrationPatternType
-
Constructor Details
-
FluxMessageChannel
public FluxMessageChannel()
-
-
Method Details
-
doSend
protected boolean doSend(org.springframework.messaging.Message<?> message, long timeout)Description copied from class:AbstractMessageChannelSubclasses 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:
doSendin classAbstractMessageChannel- Parameters:
message- The message.timeout- The timeout.- Returns:
- true if the send was successful.
-
subscribe
public void subscribe(org.reactivestreams.Subscriber<? super org.springframework.messaging.Message<?>> subscriber)- Specified by:
subscribein interfaceorg.reactivestreams.Publisher<org.springframework.messaging.Message<?>>
-
subscribeTo
public void subscribeTo(org.reactivestreams.Publisher<? extends org.springframework.messaging.Message<?>> publisher)- Specified by:
subscribeToin interfaceReactiveStreamsSubscribableChannel
-
destroy
public void destroy()- Specified by:
destroyin interfaceorg.springframework.beans.factory.DisposableBean- Specified by:
destroyin interfaceIntegrationManagement- Overrides:
destroyin classAbstractMessageChannel
-