主页
产品
Red Hat Fuse
7.7
Apache Camel 组件参考
305.5.3. 批处理消息支持

305.5.3. 批处理消息支持

Sjms2Producer 支持通过创建封装列表的 Exchange 发布一系列消息。此 Sjms2Producer 将迭代列表的内容并单独发布每条消息。

如果出现批处理消息，则需要设置每个消息唯一的标头，您可以使用 SJMS2 BatchMessage 类。当 Sjms2Producer 遇到 BatchMessage 列表时，它将迭代每个 BatchMessage 并发布包括的有效负载和标头。

以下是使用 BatchMessage 类的示例。首先，我们创建一个 BatchMessage 列表：

List<BatchMessage<String>> messages = new ArrayList<BatchMessage<String>>();
for (int i = 1; i <= messageCount; i++) {
    String body = "Hello World " + i;
    BatchMessage<String> message = new BatchMessage<String>(body, null);
    messages.add(message);
}

List<BatchMessage<String>> messages = new ArrayList<BatchMessage<String>>();
for (int i = 1; i <= messageCount; i++) {
    String body = "Hello World " + i;
    BatchMessage<String> message = new BatchMessage<String>(body, null);
    messages.add(message);
}

Copy to Clipboard

Toggle word wrap

然后发布列表：

template.sendBody("sjms2:queue:batch.queue", messages);

template.sendBody("sjms2:queue:batch.queue", messages);

Copy to Clipboard

Toggle word wrap

返回顶部

305.5.3. 批处理消息支持

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links