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, unbind
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
unbind
public 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 NamedChannelSource
public void sendPayload(java.lang.Object payload)
sendPayload
in interface NamedChannelSource
protected boolean createSink()
createSink
in class AbstractSingleNodeProcessingChain
protected boolean createSource()
createSource
in class AbstractSingleNodeProcessingChain