跳到主要内容

保证消息流

为了让客户端应用程序向 Solace PubSub+ 发布保证消息或从 Solace PubSub+ 消费保证消息,它必须在会话中创建一个或多个流。流是一个 API 对象,允许应用程序发送或接收保证消息。

订阅者流允许应用程序从端点(如队列)接收保证消息。除非另有说明,对流的引用都是指订阅者流。

当客户端发布保证消息时也会使用流。对于 JCSMP,当获取 XMLMessageProducer 时会创建生产者流。对于 Java RTO、C、JavaScript、Node.js 和 .NET API,当客户端在会话中开始发送持久消息时,会自动建立生产者流。有关发布保证消息的详细信息,请参阅发布保证消息。

PubSub+ 消息 API使用
JCSMPcom.solacesystems.jcsmp.FlowReceiver
Java RTOcom.solacesystems.solclientj.core.handle.FlowHandle
CsolClient_session_createFlow(...)
solClient_opaqueFlow_pt
.NETSolaceSystems.Solclient.Messaging.IFlow
JavaScript 和 Node.jssolace.MessageConsumer

接收消息的流 API

浏览器

浏览器允许客户端应用程序查看队列上从最旧到最新的消息,而不会删除它们。浏览消息后,它们仍然可以通过流被消费者接收。

也可以使用浏览器查看消息并有选择地从队列中删除它们。已删除的消息将不能再被消费。

在 Java 和 .NET API 中,浏览器是对象。在 Java RTO 和 C API 中,当设置特定的 FlowHandle 或流属性时,流可以充当浏览器。

JavaScript 和 Node.js API 不支持消息浏览。

PubSub+ 消息 API使用
JCSMPcom.solacesystems.jcsmp.Browser
Java RTOcom.solacesystems.solclientj.core.handle.FlowHandle.PROPERTIES.BROWSER
CSOLCLIENT_FLOW_PROP_BROWSER
.NETSolaceSystems.Solclient.Messaging.IBrowser
JavaScript 和 Node.js不适用

浏览器 API