Spring Cloud Stream и отправка сообщений в очередь партиями

Question

Я отправляю сообщения в свою очередь сообщений следующим образом

 messages.forEach(message->
    sources.output().send(MessageBuilder.withPayload(message).build());

Эти сообщения приходят из внешнего источника, и их может быть тысячи.Я видел Splitter, но он требует входной канал и выходной канал, но мои сообщения впервые попадают в очередь, я просто создаю сообщения, не потребляя их, и я не уверен, как будет работать Aggregator илиесли это было бы слишком сложно для такого простого сценария.

Так что в основном я хотел бы иметь возможность отправлять эти сообщения партиями, а не одно за другим.Как это могло быть достигнуто?

Answer 1

Для чего-то простого вы можете собрать и создать List данных (сообщений или просто полезных нагрузок), а затем создать одно сообщение с List, являющимся полезной нагрузкой, и отправить его.

Для более настраиваемого подхода вы можететакже используйте Spring Integration Aggregator