public class DelegatingMessageGroupProcessor extends ObjectSE implements MessageGroupProcessor, BeanFactoryAware, ManageableLifecycle
delegate への委譲とヘッダーのオプションの集約を使用した MessageGroupProcessor 実装。AbstractAggregatingMessageGroupProcessor とは異なり、このプロセッサーは delegate 呼び出しの結果をチェックし、結果が Message または AbstractIntegrationMessageBuilder でない場合にのみ、ヘッダーを出力に集約します。
このプロセッサーは、集約ヘッダー FunctionSE が提供されている場合に、提供されている非標準 MessageGroupProcessor をラップするために内部的に使用されます。POJO メソッドの呼び出しまたは SpEL 式の評価には、AbstractAggregatingMessageGroupProcessor 実装を使用することをお勧めします。
| コンストラクターと説明 |
|---|
DelegatingMessageGroupProcessor(MessageGroupProcessor delegate, java.util.function.FunctionSE<MessageGroup, MapSE<StringSE, ObjectSE>> headersFunction) |
| 修飾子と型 | メソッドと説明 |
|---|---|
boolean | isRunning() |
ObjectSE | processMessageGroup(MessageGroup group) 指定された MessageGroup を処理します。 |
void | setBeanFactory(BeanFactory beanFactory) |
void | start() |
void | stop() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic DelegatingMessageGroupProcessor(MessageGroupProcessor delegate, java.util.function.FunctionSE<MessageGroup,MapSE<StringSE,ObjectSE>> headersFunction)
public void setBeanFactory(BeanFactory beanFactory) throws BeansException
BeanFactoryAware の setBeanFactory BeansExceptionpublic ObjectSE processMessageGroup(MessageGroup group)
MessageGroupProcessor複数のメッセージが返される場合、戻り値は Collection <Message> でなければなりません。
MessageGroupProcessor の processMessageGroup group - メッセージグループ。public void start()
Lifecycle の start ManageableLifecycle の start public void stop()
Lifecycle の stop ManageableLifecycle の stop public boolean isRunning()
Lifecycle の isRunning ManageableLifecycle の isRunning