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