public class SingleNodeProcessingChainConsumer extends AbstractSingleNodeProcessingChain implements NamedChannelSink
NamedChannelSink to
create a complete stream.integrationSupport, sink, source| Constructor and Description |
|---|
SingleNodeProcessingChainConsumer(SingleNodeApplication application,
java.lang.String streamName,
java.lang.String processingChain) |
SingleNodeProcessingChainConsumer(SingleNodeApplication application,
java.lang.String streamName,
java.lang.String processingChain,
java.lang.String moduleResourceLocation) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
createSink() |
protected boolean |
createSource() |
org.springframework.messaging.Message<?> |
receive(int timeout) |
java.lang.Object |
receivePayload(int timeout) |
destroy, unbindclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitunbindpublic SingleNodeProcessingChainConsumer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
public SingleNodeProcessingChainConsumer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain, java.lang.String moduleResourceLocation)
public org.springframework.messaging.Message<?> receive(int timeout)
receive in interface NamedChannelSinkpublic java.lang.Object receivePayload(int timeout)
receivePayload in interface NamedChannelSinkprotected boolean createSink()
createSink in class AbstractSingleNodeProcessingChainprotected boolean createSource()
createSource in class AbstractSingleNodeProcessingChain