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() |
org.springframework.messaging.Message<?> |
receive(int timeout) |
java.lang.Object |
receivePayload() |
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()
receive in interface NamedChannelSinkpublic org.springframework.messaging.Message<?> receive(int timeout)
receive in interface NamedChannelSinkpublic java.lang.Object receivePayload()
receivePayload 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