public class ReactiveConsumer extends AbstractEndpoint
lifecycleCondition, lifecycleLockEXPRESSION_PARSER, logger| Constructor and Description |
|---|
ReactiveConsumer(MessageChannel inputChannel,
java.util.function.Consumer<Message<?>> consumer) |
ReactiveConsumer(MessageChannel inputChannel,
org.reactivestreams.Subscriber<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(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(MessageChannel inputChannel, java.util.function.Consumer<Message<?>> consumer)
public ReactiveConsumer(MessageChannel inputChannel, org.reactivestreams.Subscriber<Message<?>> subscriber)
public void setErrorHandler(ErrorHandler errorHandler)
protected void onInit()
throws Exception
IntegrationObjectSupportonInit in class IntegrationObjectSupportException - Any exception.protected void doStart()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStart in class AbstractEndpointprotected void doStop()
AbstractEndpointAbstractEndpoint.lifecycleLock.doStop in class AbstractEndpoint