public class SimpleMessageGroupProcessor extends ObjectSE implements MessageGroupProcessor
MessageGroupProcessor
。グループが完了すると、グループ化されたメッセージが個別のメッセージとして解放されるように、アグリゲーターをバリアとして構成するために使用できます。コンストラクターと説明 |
---|
SimpleMessageGroupProcessor() |
修飾子と型 | メソッドと説明 |
---|---|
ObjectSE | processMessageGroup(MessageGroup group) 指定された MessageGroup を処理します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public ObjectSE processMessageGroup(MessageGroup group)
MessageGroupProcessor
複数のメッセージが返される場合、戻り値は Collection <Message> でなければなりません。
MessageGroupProcessor
の processMessageGroup
group
- メッセージグループ。