public class SingleNodeProcessingChain extends AbstractSingleNodeProcessingChain implements NamedChannelSource, NamedChannelSink
NamedChannelSink と NamedChannelSource を追加して処理中の チェーン "p1 | p2... | pn" をテストするためのストリームを作成します。integrationSupport, sink, source| コンストラクターと説明 |
|---|
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) |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected boolean | createSink() |
protected boolean | createSource() |
org.springframework.messaging.Message<?> | receive(int timeout) |
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(int timeout)
NamedChannelSink 内の receive public java.lang.Object receivePayload(int timeout)
NamedChannelSink 内の receivePayload public void send(org.springframework.messaging.Message<?> message)
NamedChannelSource 内の send public void sendPayload(java.lang.Object payload)
NamedChannelSource 内の sendPayload protected boolean createSink()
AbstractSingleNodeProcessingChain の createSink protected boolean createSource()
AbstractSingleNodeProcessingChain の createSource