public class ReactiveStreamsConsumer extends AbstractEndpoint implements IntegrationConsumer
AbstractEndpoint implementation for Reactive Streams subscription into an
input channel and reactive consumption of messages from that channel.lifecycleCondition, lifecycleLockEXPRESSION_PARSER, logger| Constructor and Description |
|---|
ReactiveStreamsConsumer(org.springframework.messaging.MessageChannel inputChannel,
org.springframework.messaging.MessageHandler messageHandler) |
ReactiveStreamsConsumer(org.springframework.messaging.MessageChannel inputChannel,
org.springframework.messaging.ReactiveMessageHandler reactiveMessageHandler)
Instantiate an endpoint based on the provided
MessageChannel and ReactiveMessageHandler. |
ReactiveStreamsConsumer(org.springframework.messaging.MessageChannel inputChannel,
org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>> subscriber) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart()
Subclasses must implement this method with the start behavior.
|
protected void |
doStop()
Subclasses must implement this method with the stop behavior.
|
org.springframework.messaging.MessageHandler |
getHandler()
Return the consumer's handler.
|
org.springframework.messaging.MessageChannel |
getInputChannel()
Return the input channel.
|
org.springframework.messaging.MessageChannel |
getOutputChannel()
Return the output channel (may be null).
|
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setErrorHandler(org.springframework.util.ErrorHandler errorHandler) |
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, 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, waitgetBeanName, getComponentName, getComponentTypepublic ReactiveStreamsConsumer(org.springframework.messaging.MessageChannel inputChannel,
org.springframework.messaging.MessageHandler messageHandler)
public ReactiveStreamsConsumer(org.springframework.messaging.MessageChannel inputChannel,
org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>> subscriber)
public ReactiveStreamsConsumer(org.springframework.messaging.MessageChannel inputChannel,
org.springframework.messaging.ReactiveMessageHandler reactiveMessageHandler)
MessageChannel and ReactiveMessageHandler.inputChannel - the channel to consume in reactive manner.reactiveMessageHandler - the ReactiveMessageHandler to process messages.public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
public org.springframework.messaging.MessageChannel getInputChannel()
IntegrationConsumergetInputChannel in interface IntegrationConsumerpublic org.springframework.messaging.MessageChannel getOutputChannel()
IntegrationConsumergetOutputChannel in interface IntegrationConsumerpublic org.springframework.messaging.MessageHandler getHandler()
IntegrationConsumergetHandler in interface IntegrationConsumerprotected void onInit()
IntegrationObjectSupportonInit in class AbstractEndpointprotected void doStart()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStart in class AbstractEndpointprotected void doStop()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStop in class AbstractEndpoint