-
公开(公告)号:US20090287804A1
公开(公告)日:2009-11-19
申请号:US12119849
申请日:2008-05-13
CPC分类号: H04L67/147 , H04L43/50 , H04L67/14
摘要: When a new broker is connected to a network, a loop detection message is sent over the new connection created by the new broker. The loop detection message includes topics. At each receiving broker, topics that cannot be propagated to a neighbor broker are removed. If the loop detect message contains no topics, the loop detect message is not propagated further. If the loop detection message returns to the new broker, a loop is detected.
摘要翻译: 当新的代理连接到网络时,循环检测消息通过新代理创建的新连接发送。 循环检测消息包括主题。 在每个接收代理处,将删除不能传播到邻居代理的主题。 如果循环检测消息不包含主题,则循环检测消息不会进一步传播。 如果循环检测消息返回到新的代理程序,则检测到一个循环。
-
公开(公告)号:US08019847B2
公开(公告)日:2011-09-13
申请号:US12119849
申请日:2008-05-13
IPC分类号: G06F15/16
CPC分类号: H04L67/147 , H04L43/50 , H04L67/14
摘要: When a new broker is connected to a network, a loop detection message is sent over the new connection created by the new broker. The loop detection message includes topics. At each receiving broker, topics that cannot be propagated to a neighbor broker are removed. If the loop detect message contains no topics, the loop detect message is not propagated further. If the loop detection message returns to the new broker, a loop is detected.
摘要翻译: 当新的代理连接到网络时,循环检测消息通过新代理创建的新连接发送。 循环检测消息包括主题。 在每个接收代理处,将删除不能传播到邻居代理的主题。 如果循环检测消息不包含主题,则循环检测消息不会进一步传播。 如果循环检测消息返回到新的代理程序,则检测到一个循环。
-
公开(公告)号:US08200740B2
公开(公告)日:2012-06-12
申请号:US12348201
申请日:2009-01-02
摘要: Disclosed is a method comprising steps of: a broker software application receiving a first published message on a topic from a publisher application and storing the first published message in a local storage location along with an indicator which indicates that the first published message originated from a publisher application that is local to the broker software application; the broker software application receiving a second published message on the topic from another broker software application and storing the second published message in the local storage location in place of the previously stored first published message, along with an indicator which indicates that the second published message originated from a publisher application that is remote to the broker software application; and the broker software application delivering the second published message, from the local storage location, to a requesting subscriber application which has requested a last retained publication message on the topic.
摘要翻译: 公开了一种方法,包括以下步骤:代理软件应用程序从发布者应用程序接收关于主题的第一已发布消息,并将第一已发布消息存储在本地存储位置以及指示第一已发布消息来自发布者的指示符 代理软件应用程序本地的应用程序; 所述代理软件应用程序从另一代理软件应用程序接收关于所述主题的第二已发布消息,并将所述第二已发布消息存储在所述本地存储位置中,以代替先前存储的第一已发布消息,以及指示第二已发布消息发起的指示符 来自远程代理软件应用程序的发行商应用程序; 以及从本地存储位置传递第二已发布消息的代理软件应用程序到已经请求关于该主题的最后保留的发布消息的请求用户应用程序。
-
公开(公告)号:US20090177753A1
公开(公告)日:2009-07-09
申请号:US12348201
申请日:2009-01-02
IPC分类号: G06F15/16
摘要: Disclosed is a method comprising steps of: a broker software application receiving a first published message on a topic from a publisher application and storing the first published message in a local storage location along with an indicator which indicates that the first published message originated from a publisher application that is local to the broker software application; the broker software application receiving a second published message on the topic from another broker software application and storing the second published message in the local storage location in place of the previously stored first published message, along with an indicator which indicates that the second published message originated from a publisher application that is remote to the broker software application; and the broker software application delivering the second published message, from the local storage location, to a requesting subscriber application which has requested a last retained publication message on the topic.
摘要翻译: 公开了一种方法,包括以下步骤:代理软件应用程序从发布者应用程序接收关于主题的第一已发布消息,并将第一已发布消息存储在本地存储位置以及指示第一已发布消息来自发布者的指示符 代理软件应用程序本地的应用程序; 所述代理软件应用程序从另一代理软件应用程序接收关于所述主题的第二已发布消息,并将所述第二已发布消息存储在所述本地存储位置中,以代替先前存储的第一已发布消息,以及指示第二已发布消息发起的指示符 来自远程代理软件应用程序的发行商应用程序; 以及从本地存储位置传递第二已发布消息的代理软件应用程序到已经请求关于该主题的最后保留的发布消息的请求用户应用程序。
-
公开(公告)号:US08566423B2
公开(公告)日:2013-10-22
申请号:US12236563
申请日:2008-09-24
CPC分类号: G06Q30/02 , H04L67/10 , H04L67/28 , H04L67/2819 , H04L67/2842 , H04L67/306
摘要: A publish/subscribe messaging network in which a distributed set of publish/subscribe brokers comprises a first subset of publish/subscribe brokers, each arranged to store proxy subscription information for the whole of the distributed set of brokers; and a second subset of publish/subscribe brokers, each configured to send subscription information for local subscribers to one or more brokers within the first subset of publish/subscribe brokers, and configured to request, from a broker within the first subset of brokers, proxy subscription information following receipt of a message.
摘要翻译: 发布/订阅消息传递网络,其中分发的发布/订阅代理集合包括发布/订阅代理的第一子集,每个发布/订阅代理被布置为存储整个分布式代理集合的代理订阅信息; 以及发布/订阅经纪人的第二子集,每个发布/订阅经纪人被配置为向本地订户发送订阅信息给发布/订阅经纪人的第一子集内的一个或多个经纪人,并且被配置为从经纪人的第一子集内的代理人请求代理 收到消息后的订阅信息。
-
公开(公告)号:US20090138572A1
公开(公告)日:2009-05-28
申请号:US12236563
申请日:2008-09-24
IPC分类号: G06F15/16
CPC分类号: G06Q30/02 , H04L67/10 , H04L67/28 , H04L67/2819 , H04L67/2842 , H04L67/306
摘要: A publish/subscribe messaging network in which a distributed set of publish/subscribe brokers comprises a first subset of publish/subscribe brokers, each arranged to store proxy subscription information for the whole of the distributed set of brokers; and a second subset of publish/subscribe brokers, each configured to send subscription information for local subscribers to one or more brokers within the first subset of publish/subscribe brokers, and configured to request, from a broker within the first subset of brokers, proxy subscription information following receipt of a message.
摘要翻译: 发布/订阅消息传递网络,其中分发的发布/订阅代理集合包括发布/订阅代理的第一子集,每个发布/订阅代理被布置为存储整个分布式代理集合的代理订阅信息; 以及发布/订阅经纪人的第二子集,每个发布/订阅经纪人被配置为向本地订户发送订阅信息给发布/订阅经纪人的第一子集内的一个或多个经纪人,并且被配置为从经纪人的第一子集内的代理人请求代理 收到消息后的订阅信息。
-
公开(公告)号:US20170339094A1
公开(公告)日:2017-11-23
申请号:US15674271
申请日:2017-08-10
IPC分类号: H04L12/58
摘要: In response to receipt of a request message from a requester, a reply message is created. The reply message includes a message identifier of the request message copied from the received request message. The reply message is published to each of a group of replicated message queues. The reply message is identifiable by the requester using the copied message identifier of the request message on any one of the group of replicated message queues prior to being consumed by the requester.
-
公开(公告)号:US08949348B2
公开(公告)日:2015-02-03
申请号:US13015434
申请日:2011-01-27
CPC分类号: G06Q10/06
摘要: In response to publication of a topic message on a topic to a messaging system by a publisher application, a determination is made as to whether any subscriber applications are registered for the topic. In response to determining that at least one subscriber application is registered for the topic, the published topic message is delivered to each registered subscriber application. In response to determining that no subscriber applications are registered for the topic, the published topic message is stored and in response to receipt of a first subsequent subscription request from a new subscriber application for the topic, the stored published topic message is delivered to the new subscriber application.
摘要翻译: 响应于由发布者应用程序向消息传送系统发布关于主题的主题消息,确定是否为该主题注册了任何用户应用程序。 响应于确定至少一个订户应用被注册为该主题,所发布的主题消息被递送到每个注册的订户应用。 响应于确定没有为该主题注册订户应用,所发布的主题消息被存储并且响应于来自用于该主题的新订户应用的第一后续订阅请求的响应,所存储的发布的主题消息被递送到新的 用户应用程序。
-
公开(公告)号:US20110258268A1
公开(公告)日:2011-10-20
申请号:US13015434
申请日:2011-01-27
IPC分类号: G06F15/16
CPC分类号: G06Q10/06
摘要: In response to publication of a topic message on a topic to a messaging system by a publisher application, a determination is made as to whether any subscriber applications are registered for the topic. In response to determining that at least one subscriber application is registered for the topic, the published topic message is delivered to each registered subscriber application. In response to determining that no subscriber applications are registered for the topic, the published topic message is stored and in response to receipt of a first subsequent subscription request from a new subscriber application for the topic, the stored published topic message is delivered to the new subscriber application.
摘要翻译: 响应于由发布者应用程序向消息传送系统发布关于主题的主题消息,确定是否为该主题注册了任何用户应用程序。 响应于确定至少一个订户应用被注册为该主题,所发布的主题消息被递送到每个注册的订户应用。 响应于确定没有为该主题注册订户应用,所发布的主题消息被存储并且响应于来自用于该主题的新订户应用的第一后续订阅请求的响应,所存储的发布的主题消息被递送到新的 用户应用程序。
-
-
-
-
-
-
-
-