我正试图通过.NET API为我的持久主题端点创建一个订阅服务器。
在下面的方法中,我试图为持久的主题端点创建一个流。我不明白在ISubscription方法中为什么需要Session.CreateFlow实例。()
如何创建ISubscription的实例以及它应该是什么?
public void Start()
{
//Create a instance of a durable topic endpoint
topic = ContextFactory.Instance.CreateDurableTopicEn
我有一个客户端应用程序,它将消息发布到单个位置/目标,然后我需要该消息在3个单独的其他队列中结束(并随后处理)基本上是这样的用例:网站以lead形式收集客户信息。该销售线索信息被推送到restful web api。restfull web api随后将消息发布到单个位置,然后将成功结果返回给客户端。在后台,消息最终在4个队列中结束,并最终发送到4个不同的其他web服务(一些是外部的,一些是内部的)
系统需要在处理来自4个队列的所有4个队列的速度方面具有良好的性能。但引线的数量并不一定非常高。(每天可能有几百条线索)
这是我所想的图像
我创建了一个工作的Google Channel AP,现在我想向所有客户端发送一条消息。
我有两个servlet。第一个方法创建通道并告诉客户端userid和token。第二个函数由http post调用,它应该发送消息。
要向客户端发送消息,我使用:
channelService.sendMessage(new ChannelMessage(channelUserId, "This is a server message!"));
这只会将消息发送到一个客户端。我怎么才能把这个发给所有人呢?
我必须存储我用来创建通道并为每个id发送消息的每个Id吗?如何将Ids传递给第二个s