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<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, ReactiveStreamsSubscribableChannel, ComponentSourceAware, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, MessageChannel, InterceptableChannel

public class FluxMessageChannel
extends AbstractMessageChannel
implements org.reactivestreams.Publisher<Message<?>>, ReactiveStreamsSubscribableChannel, Lifecycle

The AbstractMessageChannel implementation for the Reactive Streams Publisher based on the Project Reactor Flux.

This class implements Lifecycle to control subscriptions to publishers attached via subscribeTo(Publisher), when this channel is restarted.

Since:

5.0

Author:

Artem Bilan, Gary Russell, Sergei Egorov

Nested Class Summary

Nested classes/interfaces inherited from class AbstractMessageChannel

AbstractMessageChannel.ChannelInterceptorList

Nested classes/interfaces inherited from interface IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields inherited from class AbstractMessageChannel

interceptors, meters

Fields inherited from class IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
FluxMessageChannel()

Method Summary

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

Methods inherited from class AbstractMessageChannel

addInterceptor, addInterceptor, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isApplicationRunning, isLoggingEnabled, isObserved, onInit, registerMetricsCaptor, registerObservationRegistry, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setObservationConvention, setShouldTrack

Methods inherited from class IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface IntegrationManagement

getManagedName, getManagedType, getThisAs, setManagedName, setManagedType

Methods inherited from interface NamedComponent

getBeanName, getComponentName

Methods inherited from interface ReactiveStreamsSubscribableChannel

getIntegrationPatternType

Constructor Details

FluxMessageChannel

public FluxMessageChannel()

Method Details

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<?>>

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

subscribeTo

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

Specified by:

subscribeTo in interface ReactiveStreamsSubscribableChannel

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean

Specified by:

destroy in interface IntegrationManagement

Overrides:

destroy in class AbstractMessageChannel