public class SingleNodeProcessingChain extends AbstractSingleNodeProcessingChain implements NamedChannelSource, NamedChannelSink
NamedChannelSink and
NamedChannelSource.integrationSupport, sink, source| Constructor and Description |
|---|
SingleNodeProcessingChain(SingleNodeApplication application,
java.lang.String streamName,
java.lang.String processingChain) |
SingleNodeProcessingChain(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) |
void |
send(org.springframework.messaging.Message<?> message) |
void |
sendPayload(java.lang.Object payload) |
destroy, unbindclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitunbindpublic SingleNodeProcessingChain(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
public SingleNodeProcessingChain(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 NamedChannelSinkpublic void send(org.springframework.messaging.Message<?> message)
send in interface NamedChannelSourcepublic void sendPayload(java.lang.Object payload)
sendPayload in interface NamedChannelSourceprotected boolean createSink()
createSink in class AbstractSingleNodeProcessingChainprotected boolean createSource()
createSource in class AbstractSingleNodeProcessingChain