公开(公告)号：US20100306365A1

公开(公告)日：2010-12-02

申请号：US12475959

申请日：2009-06-01

申请人： Martin J. Gale ,  Jane P. Porter ,  Andrew J. Stanford-Clark

发明人： Martin J. Gale ,  Jane P. Porter ,  Andrew J. Stanford-Clark

IPC分类号： G06F15/16 ,  G06F15/173

CPC分类号： H04L67/02 ,  H04L51/14

摘要： A method and system for controlling message throughput rates of clients connected to a broker device in a publish/subscribe network are disclosed. The broker device determines a maximum allowable message throughput for each client connected to the broker device. If a message-producing rate of a client exceeds the maximum allowable message throughput of the client, the broker device sends a negative acknowledgement (NACK) packet to the client and messages from the client are not accepted at the broker device. The NACK packet includes a maximum allowable message throughput of the client, so the client can adjust its message-producing rate based on the maximum allowable message throughput of the client. The present invention can be applied to a publish/subscribe network as well as a TCP/IP network.

摘要翻译： 公开了一种用于控制在发布/订阅网络中连接到代理设备的客户端的消息吞吐率的方法和系统。 代理设备确定连接到代理设备的每个客户端的最大允许消息吞吐量。 如果客户端的消息产生速率超过客户端的最大允许消息吞吐量，则代理设备向客户端发送否定确认（NACK）分组，并且在代理设备处不接受来自客户端的消息。 NACK分组包括客户端的最大允许消息吞吐量，因此客户端可以基于客户端的最大允许消息吞吐量来调整其消息产生速率。 本发明可以应用于发布/订阅网络以及TCP / IP网络。

公开(公告)号：US08140952B2

公开(公告)日：2012-03-20

申请号：US10976262

申请日：2004-10-28

申请人： Andrew J. F. Bravery ,  Martin J. Gale ,  Roland A. Merrick ,  Andrew J. Stanford-Clark

发明人： Andrew J. F. Bravery ,  Martin J. Gale ,  Roland A. Merrick ,  Andrew J. Stanford-Clark

IPC分类号： G06F17/21

CPC分类号： G06F17/243

摘要： A method of assisting a user, for use in an environment comprising: a user session, an external entity session and a forms engine for generating a form. The method comprises the steps of: registering with the user session, wherein a first session is established between the user session and the forms engine; receiving a request for assistance from a user; in response to receiving the request, de-registering with the user session, wherein the first session is un-established; registering with the external entity session, wherein a second session is established between the external entity session and the forms engine; receiving input from the external entity session; and populating the form with the received input.

摘要翻译： 一种辅助用户的方法，用于环境中，包括：用户会话，外部实体会话和用于生成表单的表单引擎。 该方法包括以下步骤：向用户会话注册，其中在用户会话和表单引擎之间建立第一会话; 接收用户的协助请求; 响应于接收到所述请求，对所述用户会话进行注销，其中所述第一会话是未建立的; 向所述外部实体会话注册，其中在所述外部实体会话和所述表单引擎之间建立第二会话; 从外部实体会话接收输入; 并使用接收到的输入填充表单。

公开(公告)号：US08392555B2

公开(公告)日：2013-03-05

申请号：US12475959

申请日：2009-06-01

申请人： Martin J. Gale ,  Jane P. Porter ,  Andrew J. E. Stanford-Clark

发明人： Martin J. Gale ,  Jane P. Porter ,  Andrew J. E. Stanford-Clark

IPC分类号： G06F15/173

CPC分类号： H04L67/02 ,  H04L51/14

摘要： A method and system for controlling message throughput rates of clients connected to a broker device in a publish/subscribe network are disclosed. The broker device determines a maximum allowable message throughput for each client connected to the broker device. If a message-producing rate of a client exceeds the maximum allowable message throughput of the client, the broker device sends a negative acknowledgement (NACK) packet to the client and messages from the client are not accepted at the broker device. The NACK packet includes a maximum allowable message throughput of the client, so the client can adjust its message-producing rate based on the maximum allowable message throughput of the client. The present invention can be applied to a publish/subscribe network as well as a TCP/IP network.

摘要翻译： 公开了一种用于控制在发布/订阅网络中连接到代理设备的客户端的消息吞吐率的方法和系统。 代理设备确定连接到代理设备的每个客户端的最大允许消息吞吐量。 如果客户端的消息产生速率超过客户端的最大允许消息吞吐量，则代理设备向客户端发送否定确认（NACK）分组，并且在代理设备处不接受来自客户端的消息。 NACK分组包括客户端的最大允许消息吞吐量，因此客户端可以基于客户端的最大允许消息吞吐量来调整其消息产生速率。 本发明可以应用于发布/订阅网络以及TCP / IP网络。

公开(公告)号：US08577979B2

公开(公告)日：2013-11-05

申请号：US13434542

申请日：2012-03-29

申请人： Rohit Bhasin ,  Martin J. Gale ,  Matthew I. Roberts

发明人： Rohit Bhasin ,  Martin J. Gale ,  Matthew I. Roberts

IPC分类号： G06F15/16

CPC分类号： G06F9/546

摘要： One or more policies to be applied to a set of one or more messages in a message oriented middleware are defined. Metrics of the message oriented middleware are monitored. Application of a policy in response to a trigger condition being satisfied is initiated. Application of the policy applies actions across the set of one or more messages.

摘要翻译： 定义了应用于面向消息的中间件中的一个或多个消息集合的一个或多个策略。 监视面向消息的中间件的度量。 启动响应于满足触发条件的策略的应用。 该策略的应用程序将在整个一个或多个消息集中应用操作。

公开(公告)号：US08261293B2

公开(公告)日：2012-09-04

申请号：US12176689

申请日：2008-07-21

申请人： Benjamin J. Fletcher ,  Martin J. Gale

发明人： Benjamin J. Fletcher ,  Martin J. Gale

IPC分类号： G06F3/00

CPC分类号： G06F9/546 ,  H04L43/0811

摘要： An exemplary embodiment includes a method for pairing an application name and a client ID in a messaging broker infrastructure, the method including running a messaging system associated with the messaging broker infrastructure running a monitoring application configured to monitor a connection to the messaging broker, creating a connection to the messaging broker, identifying a class name and the client ID associated with an application, converting the class name to an application name and publishing a pairing of the application name and the client ID on the messaging infrastructure.

摘要翻译： 示例性实施例包括用于在消息传递代理基础设施中配对应用程序名称和客户机ID的方法，该方法包括运行与消息传递代理基础架构相关联的消息传递系统，其运行监视应用程序，该监视应用程序被配置为监视与消息传递代理的连接， 与消息传递代理的连接，识别与应用程序相关联的类名称和客户端ID，将类名称转换为应用程序名称，并在消息传递基础结构上发布应用程序名称和客户端ID的配对。

公开(公告)号：US20120215859A1

公开(公告)日：2012-08-23

申请号：US13033005

申请日：2011-02-23

申请人： Kulvir S. Bhogal ,  Martin J. Gale ,  Rick A. Hamilton, II ,  Andrew R. Jones ,  Brian M. O'Connell

发明人： Kulvir S. Bhogal ,  Martin J. Gale ,  Rick A. Hamilton, II ,  Andrew R. Jones ,  Brian M. O'Connell

IPC分类号： G06F15/16

CPC分类号： H04L67/2842 ,  G06F9/546 ,  G06F2209/547 ,  H04L12/1859 ,  H04L51/066 ,  H04L51/08 ,  H04L51/14

摘要： Embodiments of the present invention provide an approach for a publisher-assisted, broker-based cache that can be utilized to reduce a volume of data (e.g., network traffic) delivered between a publisher and broker in a publication/subscription (pub/sub) environment. Specifically, in a typical embodiment, when a message is being generated on a publisher system, the publisher system will determine if the message includes a set of data that has a potential to be repeated in subsequent messages. Once such a set of data has been identified, the set of data will be associated/marked/tagged (e.g., in the message) with a unique identifier/cache key corresponding thereto (i.e., to yield a modified message). The modified message will be sent to a broker system, which will detect/locate the unique identifier, cache the corresponding data, and send the message along to any applicable subscriber systems. When a subsequent message that is supposed to contain the cached set of data is generated, the publisher system will instead substitute the unique identifier for the set of data to yield an abbreviated message and send the abbreviated message to the broker system. Upon receipt, the broker system will detect/locate the unique identifier, retrieve the corresponding set of data from the cache, replace the unique identifier with the set of data to yield a completed message, and then send the completed message to the applicable subscriber systems.

摘要翻译： 本发明的实施例提供了一种用于发布商辅助的基于经纪人的高速缓存的方法，其可以用于减少在发布/订阅（pub / sub）中发布者和代理之间递送的数据量（例如，网络流量） 环境。 具体地，在典型的实施例中，当在发布者系统上生成消息时，发布者系统将确定该消息是否包括在后续消息中具有重复潜力的一组数据。 一旦已经识别出这样的一组数据，该组数据将与其对应的唯一标识符/高速缓存密钥相关联（例如，在消息中）（即产生修改的消息）。 修改的消息将被发送到代理系统，其将检测/定位唯一标识符，缓存对应的数据，并将消息发送到任何适用的订户系统。 当生成包含缓存的数据集的后续消息时，发布者系统将替代替代数据集的唯一标识符来产生缩写消息并将缩写消息发送到代理系统。 代理系统在收到时将检测/定位唯一标识符，从高速缓存中检索相应的数据集，用该组数据替换唯一标识符以产生完成的消息，然后将完成的消息发送到适用的订户系统 。

公开(公告)号：US20120215858A1

公开(公告)日：2012-08-23

申请号：US13032974

申请日：2011-02-23

申请人： Kulvir S. Bhogal ,  Martin J. Gale ,  Rick A. Hamilton, II ,  Andrew R. Jones ,  Brian M. O'Connell

发明人： Kulvir S. Bhogal ,  Martin J. Gale ,  Rick A. Hamilton, II ,  Andrew R. Jones ,  Brian M. O'Connell

IPC分类号： G06F15/16

摘要： In general, embodiments of the present invention provide an approach for caching potentially repetitive data in a publication-subscription (pub/sub) system. Specifically, in a typical embodiment, when a message is received on a broker system from a publisher system, the broker system analyzes the message for potentially repetitive data. Such data can be determined from historical messages (e.g., determining that a certain set of data appeared in multiple messages and is thus flagged in a database or the like), a set of rules (e.g., if data set “Y” appears, flag it as potentially repetitive), etc. Regardless, once such a set of data has been identified, the set of data will be tagged/marked in the message with a unique identifier. The message and inserted unique identifier is then sent to the relevant subscriber system(s). Upon receiving the message, the subscriber system(s) will analyze the message, identify the unique identifier, and cache the tagged data. Thereafter, when the publisher system receives another message that contains the same set of data that was previously tagged, the publisher system will substitute the unique identifier for the repeated data to yield an abbreviated message. The publisher system will then send the abbreviated message to the subscriber system(s), which will analyze the abbreviated message, identify the unique identifier, and retrieve the associated data from cache. Thus, the substitution of unique identifiers for potentially repetitive data can avoid unnecessary communication of data and reduce overall network bandwidth consumption.

摘要翻译： 通常，本发明的实施例提供了用于在发布订阅（pub / sub）系统中缓存潜在的重复数据的方法。 具体来说，在典型的实施例中，当代理系统从发布者系统接收到消息时，代理系统分析该消息以获得潜在的重复数据。 这样的数据可以从历史消息中确定（例如，确定某组数据出现在多个消息中并因此被标记在数据库中等等），一组规则（例如，如果数据集“Y”出现，则标志 它可能重复）等。无论如何，一旦这样一组数据被识别，该组数据将被标记/标记在消息中具有唯一的标识符。 然后将消息和插入的唯一标识符发送到相关订户系统。 一旦接收到消息，订户系统将分析消息，识别唯一标识符，并缓存标记的数据。 此后，当发布者系统接收到包含先前标记的相同数据集的另一消息时，发布者系统将替换重复数据的唯一标识符来产生缩写消息。 然后，发布者系统将将缩写消息发送到用户系统，用户系统将分析缩写消息，识别唯一标识符，并从缓存中检索关联的数据。 因此，将唯一标识符替换为可能重复的数据可以避免不必要的数据通信并减少总体网络带宽消耗。

公开(公告)号：US08250032B2

公开(公告)日：2012-08-21

申请号：US12476558

申请日：2009-06-02

申请人： Benjamin J. Fletcher ,  Martin J. Gale ,  Neil G. Young

发明人： Benjamin J. Fletcher ,  Martin J. Gale ,  Neil G. Young

IPC分类号： G06F7/00 ,  G06F17/00

CPC分类号： G06F17/30949

摘要： A method, a system and a computer program product for matching a publication to at least one subscriber are disclosed. After receiving a publication request, a matching engine accesses a hash table to determine whether there is a non-wildcarded match corresponding to the publication request. If the matching engine finds the non-wildcarded match in the hash table, the matching engine omits validating a topic of the publication and provides the non-wildcarded match to the broker device without waiting for a result of searching a wildcarded match. Otherwise, the matching engine validates the topic of the publication. The matching engine also starts to search a wildcarded match in a wildcarded subscription data store. Upon finding the wildcarded match, the matching engine provides the wildcarded match to the broker device. The matching engine provides each result of the findings asynchronously to the broker device.

摘要翻译： 公开了一种用于将出版物与至少一个订户进行匹配的方法，系统和计算机程序产品。 在接收到发布请求之后，匹配引擎访问散列表以确定是否存在与发布请求相对应的非通配符。 如果匹配引擎在哈希表中找到非通配符，则匹配引擎将忽略验证发布的主题，并向代理设备提供非通配符匹配，而不必等待搜索通配符匹配的结果。 否则，匹配引擎验证出版物的主题。 匹配引擎还开始在通配符订阅数据存储中搜索通配符。 在找到通配符匹配后，匹配引擎将通配符匹配提供给代理设备。 匹配引擎将异常结果的每个结果与经纪人设备进行异步。

公开(公告)号：US07512893B2

公开(公告)日：2009-03-31

申请号：US11363117

申请日：2006-02-27

申请人： Martin J. Gale ,  Andrew James Bravery ,  John Frederick Clarke

发明人： Martin J. Gale ,  Andrew James Bravery ,  John Frederick Clarke

IPC分类号： G06F13/00 ,  G06F15/00

CPC分类号： G06F9/451

摘要： A system for transmitting an input stream for use with an apparatus comprising a plurality of entities (e.g. applications, processes etc.) wherein each entity comprises an associated entity profile having associated profile data. The system comprises: a focus component for detecting focus of a first entity and an intercept component for intercepting the input stream having input data, before the input stream is input to the focused first entity. A match component matches the input data with first profile data of a first entity profile associated with the focused first entity. In response to the input data not matching the first profile data, the match component matches the input data with second profile data of a second entity profile associated with a second entity. In response to the input data matching the second profile data, the input stream is transmitted to the second entity.

摘要翻译： 一种用于发送用于包括多个实体（例如，应用，过程等）的设备的输入流的系统，其中每个实体包括具有相关联的简档数据的相关联的实体简档。 该系统包括：在输入流被输入到聚焦的第一实体之前，用于检测第一实体的焦点的焦点部分和用于截取具有输入数据的输入流的截距分量。 匹配组件将输入数据与与聚焦的第一实体相关联的第一实体简档的第一简档数据进行匹配。 响应于与第一简档数据不匹配的输入数据，匹配组件将输入数据与与第二实体相关联的第二实体简档的第二简档数据进行匹配。 响应于与第二简档数据匹配的输入数据，输入流被发送到第二实体。

公开(公告)号：US20070271502A1

公开(公告)日：2007-11-22

申请号：US11626946

申请日：2007-01-25

申请人： Bharat Veer Bedi ,  Marc Stanley Carter ,  Martin J. Gale ,  Lucas William Partridge ,  Andrew James Stanford-Clark

发明人： Bharat Veer Bedi ,  Marc Stanley Carter ,  Martin J. Gale ,  Lucas William Partridge ,  Andrew James Stanford-Clark

IPC分类号： G06F17/00 ,  G06F3/00

CPC分类号： G06F17/248

摘要： A method and system for collaborative editing of a document by an author of the document and reviewers. Program code receives from the author an identification of selected portions of the document and receives from the author: comments created by the author and an identification of at least one reviewer to which each comment is directed. The selected portions and the comments are associated with each other on a one-to-one basis. Each comment pertains to content of the selected portion that each comment is associated with. The program code parses the received comments, and utilizes the identification of the at least one reviewer to which each comment is directed, to generate a list of comments specifying for each comment the at least one reviewer to which each comment is directed. The program code makes available to each reviewer the comments on the list of comments directed to each reviewer.

摘要翻译： 由文档作者和审稿人协作编辑文件的方法和系统。 程序代码从作者收到文件的选定部分的标识，并从作者收到：作者创建的评论和每个评论所针对的至少一个评论者的标识。 所选择的部分和注释在一对一的基础上彼此相关联。 每个评论都与每个评论相关联的所选部分的内容相关。 程序代码解析所接收的评论，并且利用每个评论所针对的至少一个审阅者的标识来生成针对每个评论指定每个评论的评论列表，该列表针对每个评论所针对的至少一个审阅者。 程序代码为每个审阅者提供针对每个审阅者的评论列表的评论。