public class ReactiveConsumer extends AbstractEndpoint
lifecycleCondition, lifecycleLockEXPRESSION_PARSER, logger| Constructor and Description |
|---|
ReactiveConsumer(org.springframework.messaging.MessageChannel inputChannel,
java.util.function.Consumer<org.springframework.messaging.Message<?>> consumer) |
ReactiveConsumer(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.
|
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setErrorHandler(org.springframework.util.ErrorHandler errorHandler) |
doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toStringpublic ReactiveConsumer(org.springframework.messaging.MessageChannel inputChannel,
java.util.function.Consumer<org.springframework.messaging.Message<?>> consumer)
public ReactiveConsumer(org.springframework.messaging.MessageChannel inputChannel,
org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>> subscriber)
public void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
protected void onInit()
throws java.lang.Exception
IntegrationObjectSupportonInit in class IntegrationObjectSupportjava.lang.Exception - Any exception.protected void doStart()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStart in class AbstractEndpointprotected void doStop()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStop in class AbstractEndpoint