public class SingleNodeProcessingChainProducer extends AbstractSingleNodeProcessingChain implements NamedChannelSource
NamedChannelSource to
create a complete stream.integrationSupport, sink, source| Constructor and Description |
|---|
SingleNodeProcessingChainProducer(SingleNodeApplication application,
java.lang.String streamName,
java.lang.String processingChain) |
SingleNodeProcessingChainProducer(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() |
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 SingleNodeProcessingChainProducer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain)
public SingleNodeProcessingChainProducer(SingleNodeApplication application, java.lang.String streamName, java.lang.String processingChain, java.lang.String moduleResourceLocation)
public 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