跳到主要内容

在PubSub+ JCSMP API中创建临时端点

使用 PubSub+ JCSMP API 的客户端可以从临时端点（临时队列或非持久主题端点）消费保证消息。然而，临时端点是非持久的，因为它只存在于创建它的会话中。

客户端应用程序创建临时端点实例后，当为该临时端点创建流时，事件代理会自动配置一个匹配的端点对象。要为临时端点创建流，客户端应用程序可以调用 JCSMPSession.createFlow(endpointToBindTo,newSubscription,messageListener)，它会返回一个 FlowReceiver 对象。

当你调用 FlowReceiver 上的 close() 函数时，如果流绑定到非持久端点，那么事件代理会删除非持久端点及其累积的消息。

相关示例​

有关如何动态创建临时队列的示例，请参阅 Solace 开发者中心上的 SimpleFlowToQueue 示例。

有关如何动态创建临时主题端点的示例，请参阅 Solace 开发者中心上的 SimpleFlowToTopic 示例。

要为临时队列创建临时端点，请使用以下方法：

  • JCSMPSession.CreateTemporaryQueue() 创建一个具有自动生成名称的临时队列。

  • JCSMPSession.CreateTemporaryQueue(String name) 根据给定的名称创建一个临时队列。

要为非持久主题端点创建临时端点，请使用以下方法：

  • JCSMPSession.CreateNonDurableTopicEndpoint() 创建一个具有自动生成名称的非持久主题端点。

  • JCSMPSession.CreateNonDurableTopicEndpoint(String name) 根据给定的名称创建一个非持久主题端点。