public class ReactiveStreamsConsumer extends AbstractEndpoint implements IntegrationConsumer
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
Constructor and Description |
---|
ReactiveStreamsConsumer(org.springframework.messaging.MessageChannel inputChannel,
org.springframework.messaging.MessageHandler messageHandler) |
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, setTaskScheduler, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName, getComponentType
public 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 void setErrorHandler(org.springframework.util.ErrorHandler errorHandler)
public org.springframework.messaging.MessageChannel getInputChannel()
IntegrationConsumer
getInputChannel
in interface IntegrationConsumer
public org.springframework.messaging.MessageChannel getOutputChannel()
IntegrationConsumer
getOutputChannel
in interface IntegrationConsumer
public org.springframework.messaging.MessageHandler getHandler()
IntegrationConsumer
getHandler
in interface IntegrationConsumer
protected void onInit() throws java.lang.Exception
IntegrationObjectSupport
onInit
in class AbstractEndpoint
java.lang.Exception
- Any exception.protected void doStart()
AbstractEndpoint
AbstractEndpoint.lifecycleLock
.doStart
in class AbstractEndpoint
protected void doStop()
AbstractEndpoint
AbstractEndpoint.lifecycleLock
.doStop
in class AbstractEndpoint