public class SingleNodeProcessingChainConsumer extends AbstractSingleNodeProcessingChain implements NamedChannelSink
NamedChannelSink を追加して完全なストリームを作成します。integrationSupport, sink, source| コンストラクターと説明 |
|---|
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) |
| 修飾子と型 | メソッドと説明 |
|---|---|
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)
NamedChannelSink 内の receive public java.lang.Object receivePayload(int timeout)
NamedChannelSink 内の receivePayload protected boolean createSink()
AbstractSingleNodeProcessingChain の createSink protected boolean createSource()
AbstractSingleNodeProcessingChain の createSource