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, unbind
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
unbind
public 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