public class DelegatingMessageGroupProcessor extends ObjectSE implements MessageGroupProcessor, BeanFactoryAware, ManageableLifecycle
delegate
への委譲とヘッダーのオプションの集約を使用した MessageGroupProcessor
実装。AbstractAggregatingMessageGroupProcessor
とは異なり、このプロセッサーは delegate
呼び出しの結果をチェックし、結果が Message
または AbstractIntegrationMessageBuilder
でない場合にのみ、ヘッダーを出力に集約します。
このプロセッサーは、集約ヘッダー Function
SE が提供されている場合に、提供されている非標準 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, waitSE
public DelegatingMessageGroupProcessor(MessageGroupProcessor delegate, java.util.function.FunctionSE<MessageGroup,MapSE<StringSE,ObjectSE>> headersFunction)
public void setBeanFactory(BeanFactory beanFactory) throws BeansException
BeanFactoryAware
の setBeanFactory
BeansException
public 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