-
公开(公告)号：US09104503B2
公开(公告)日：2015-08-11
申请号：US13434576
申请日：2012-03-29
摘要： A client computer group is created at a server computer by selecting a subset of a group of client computers, where each of the group of client computers has a separate communication channel with the server computer. A message from at least one of the subset of the group of client computers is received at the server computer. In response to receiving messages from at least two of the subset of the group of client computers within the client computer group, the messages are grouped under a single unit of work. A single decision associated with the single unit of work for the client computer group is computed. Each of the at least two of the subset of the group of client computers is operable to accept the single decision.
摘要翻译： 通过选择一组客户端计算机的子集，在服务器计算机上创建客户端计算机组，其中每组客户端计算机与服务器计算机具有单独的通信信道。 在服务器计算机处接收来自该组客户端计算机的至少一个子集的消息。 响应于从客户端计算机组内的客户端计算机组中的至少两个子集接收消息，消息被分组在单个工作单元下。 计算与客户端计算机组的单个工作单元相关联的单个决策。 客户端计算机组的子集中的至少两个子集中的每一个可操作以接受单个决定。
-
公开(公告)号：US09032012B2
公开(公告)日：2015-05-12
申请号：US13169988
申请日：2011-06-27
CPC分类号： H04L47/522 , G06F9/544 , H04L51/26
摘要： Embodiments of the present invention provide a method, system and computer program product for configurable pacing in messaging systems. In an embodiment of the invention, a configurable message pacing method has been provided. The method includes receiving a message directed for placement in a repository of an intermediate messaging system into which messages are placed by message producing applications and from which messages are retrieved by message consuming applications. Thereafter, it can be determined if the placement of the received message into the repository will result in a breach of an associated threshold value for the repository. Consequently, a message pacing action can be triggered responsive to the determination that the placement of the received message into the repository will result in a breach of the associated threshold value for the repository.
摘要翻译： 本发明的实施例提供了一种用于消息系统中的可配置起搏的方法，系统和计算机程序产品。 在本发明的实施例中，提供了一种可配置的消息起搏方法。 该方法包括接收定向用于放置在中间消息收发系统的存储库中的消息，通过产生消息的应用将消息放置到消息中，并且消息消费应用从哪个消息中检索消息。 此后，可以确定接收到的消息的放置是否将导致存储库的相关阈值的违反。 因此，可以响应于确定接收到的消息到存储库中的放置将导致存储库的相关阈值的违反而触发消息起搏动作。
-
3.发明授权Mechanism for delivering messages to competing consumers in a point-to-point system 失效在点对点系统中向竞争消费者传递消息的机制公开(公告)号：US07525964B2
公开(公告)日：2009-04-28
申请号：US10980034
申请日：2004-11-03
申请人： Mark C. Astley , Andrew D. J. Banks , Sumeer K. Bhola , Ignacio Silva-Lepe , Michael J. Ward , David Ware
发明人： Mark C. Astley , Andrew D. J. Banks , Sumeer K. Bhola , Ignacio Silva-Lepe , Michael J. Ward , David Ware
IPC分类号： H04L12/24
CPC分类号： H04L67/2814 , H04L67/26 , H04L67/2842 , H04L67/322
摘要： A method, system, and computer program for delivering messages and data to competing consumers. One aspect of the invention includes a message delivery system including a destination messaging engine, one or more receiver messaging engines, and a message pool. The destination messaging engine is configured to distribute data from one or more producers. The receiver messaging engines are configured to request data from the destination messaging engine and transmit the data to one or more consumers. The message pool is configured to store data from the producers, with the destination messaging engine arbitrating data in the message pool among the receiver messaging engines.
摘要翻译： 用于将消息和数据传递给竞争消费者的方法，系统和计算机程序。 本发明的一个方面包括消息传递系统，其包括目的地消息收发引擎，一个或多个接收者消息传递引擎和消息池。 目的地消息传递引擎被配置为从一个或多个生产者分发数据。 接收器消息传递引擎被配置为从目的地消息收发引擎请求数据并将数据发送到一个或多个消费者。 消息池被配置为存储来自生产者的数据，目的地消息收发引擎在接收器消息传递引擎之间对消息池中的数据进行仲裁。
-
公开(公告)号：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.
摘要翻译： 响应于由发布者应用程序向消息传送系统发布关于主题的主题消息，确定是否为该主题注册了任何用户应用程序。 响应于确定至少一个订户应用被注册为该主题，所发布的主题消息被递送到每个注册的订户应用。 响应于确定没有为该主题注册订户应用，所发布的主题消息被存储并且响应于来自用于该主题的新订户应用的第一后续订阅请求的响应，所存储的发布的主题消息被递送到新的 用户应用程序。
-
公开(公告)号：US20110320530A1
公开(公告)日：2011-12-29
申请号：US13154377
申请日：2011-06-06
IPC分类号： G06F15/16
CPC分类号： H04L67/32 , G06F9/54 , H04L67/42 , H05K999/99
摘要： A client computer group is created at a server computer by selecting a subset of a group of client computers, where each of the group of client computers has a separate communication channel with the server computer. A message from at least one of the subset of the group of client computers is received at the server computer. In response to receiving messages from at least two of the subset of the group of client computers within the client computer group, the messages are grouped under a single unit of work. A single decision associated with the single unit of work for the client computer group is computed. Each of the at least two of the subset of the group of client computers is operable to accept the single decision.
摘要翻译： 通过选择一组客户端计算机的子集，在服务器计算机上创建客户端计算机组，其中每组客户端计算机与服务器计算机具有单独的通信信道。 在服务器计算机处接收来自该组客户端计算机的至少一个子集的消息。 响应于从客户端计算机组内的客户端计算机组中的至少两个子集接收消息，消息被分组在单个工作单元下。 计算与客户端计算机组的单个工作单元相关联的单个决策。 客户端计算机组的子集中的至少两个子集中的每一个可操作以接受单个决定。
-
公开(公告)号：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.
摘要翻译： 响应于由发布者应用程序向消息传送系统发布关于主题的主题消息，确定是否为该主题注册了任何用户应用程序。 响应于确定至少一个订户应用被注册为该主题，所发布的主题消息被递送到每个注册的订户应用。 响应于确定没有为该主题注册订户应用，所发布的主题消息被存储并且响应于来自用于该主题的新订户应用的第一后续订阅请求的响应，所存储的发布的主题消息被递送到新的 用户应用程序。
-
公开(公告)号：US07466648B2
公开(公告)日：2008-12-16
申请号：US11044598
申请日：2005-01-27
申请人： Andrew D J Banks , David Ware
发明人： Andrew D J Banks , David Ware
CPC分类号： H04L1/1874
摘要： There is disclosed a source messaging system having a queue for receiving messages. The source messaging system has means for determining whether a message should be permitted to become INDOUBT. This is done by retrieving a value denoting the maximum number of messages that may be permitted to become INDOUBT at any one time; determining whether the message falls within the range denoted by the value; and responsive to determining that the message falls within the range, permitting the message to become INDOUBT.
摘要翻译： 公开了一种具有用于接收消息的队列的源消息传递系统。 源消息传递系统具有用于确定消息是否应被允许变为INDOUBT的装置。 这是通过检索表示任何一次可能被允许变为INDOUBT的消息的最大数量的值来完成的; 确定消息是否落在由该值表示的范围内; 并且响应于确定消息落在该范围内，允许该消息变为INDOUBT。
-
公开(公告)号：US08289838B2
公开(公告)日：2012-10-16
申请号：US12270328
申请日：2008-11-13
申请人： Andrew D J Banks , David Ware
发明人： Andrew D J Banks , David Ware
CPC分类号： H04L1/1874
摘要： There is disclosed a source messaging system having a queue for receiving messages. The source messaging system has means for determining whether a message should be permitted to become INDOUBT. This is done by retrieving a value denoting the maximum number of messages that may be permitted to become INDOUBT at any one time; determining whether the message falls within the range denoted by the value; and responsive to determining that the message falls within the range, permitting the message to become INDOUBT.
摘要翻译： 公开了一种具有用于接收消息的队列的源消息传递系统。 源消息传递系统具有用于确定消息是否应被允许变为INDOUBT的装置。 这是通过检索表示任何一次可能被允许变为INDOUBT的消息的最大数量的值来完成的; 确定消息是否落在由该值表示的范围内; 并且响应于确定消息落在该范围内，允许消息变为INDOUBT。
-
公开(公告)号：US20120191772A1
公开(公告)日：2012-07-26
申请号：US13434576
申请日：2012-03-29
IPC分类号： G06F15/16
摘要： A client computer group is created at a server computer by selecting a subset of a group of client computers, where each of the group of client computers has a separate communication channel with the server computer. A message from at least one of the subset of the group of client computers is received at the server computer. In response to receiving messages from at least two of the subset of the group of client computers within the client computer group, the messages are grouped under a single unit of work. A single decision associated with the single unit of work for the client computer group is computed. Each of the at least two of the subset of the group of client computers is operable to accept the single decision.
摘要翻译： 通过选择一组客户端计算机的子集，在服务器计算机上创建客户端计算机组，其中每组客户端计算机与服务器计算机具有单独的通信信道。 在服务器计算机处接收来自该组客户端计算机的至少一个子集的消息。 响应于从客户端计算机组内的客户端计算机组中的至少两个子集接收消息，消息被分组在单个工作单元下。 计算与客户端计算机组的单个工作单元相关联的单个决策。 客户端计算机组的子集中的至少两个子集中的每一个可操作以接受单个决定。
-
公开(公告)号：US20090122696A1
公开(公告)日：2009-05-14
申请号：US12270328
申请日：2008-11-13
申请人： Andrew D J Banks , David Ware
发明人： Andrew D J Banks , David Ware
CPC分类号： H04L1/1874
摘要： There is disclosed a source messaging system having a queue for receiving messages. The source messaging system has means for determining whether a message should be permitted to become INDOUBT. This is done by retrieving a value denoting the maximum number of messages that may be permitted to become INDOUBT at any one time; determining whether the message falls within the range denoted by the value; and responsive to determining that the message falls within the range, permitting the message to become INDOUBT.
摘要翻译： 公开了一种具有用于接收消息的队列的源消息传递系统。 源消息传递系统具有用于确定消息是否应被允许变为INDOUBT的装置。 这是通过检索表示任何一次可能被允许变为INDOUBT的消息的最大数量的值来完成的; 确定消息是否落在由该值表示的范围内; 并且响应于确定消息落在该范围内，允许消息变为INDOUBT。
-
-
-
-
-
-
-
-
-
搜索结果
10 条记录 (耗时 0.015 秒)
