公开(公告)号：US08561084B2

公开(公告)日：2013-10-15

申请号：US12199059

申请日：2008-08-27

Applicant: Tom Evans ,  Graham D. Wallis ,  David Ware ,  Christopher Wilkinson

Inventor： Tom Evans ,  Graham D. Wallis ,  David Ware ,  Christopher Wilkinson

IPC: G06F3/00

CPC classification number: G06F9/546

Abstract: A method of performing message operations includes receiving a message operation request identifying a queue, retrieving a list of the subset of partitions associated with the alias received in the request, and selecting at least one of the partitions within the retrieved subset. According to the method, the queue includes a plurality of partitions, the request identifies the queue with an alias, and the alias having a subset of the plurality of partitions associated therewith.

Abstract translation: 执行消息操作的方法包括接收标识队列的消息操作请求，检索与在请求中接收到的别名相关联的分区的子集的列表，以及选择所检索的子集中的至少一个分区。 根据该方法，队列包括多个分区，所述请求使用别名识别队列，并且所述别名具有与其相关联的多个分区的子集。

公开(公告)号：US20110289173A1

公开(公告)日：2011-11-24

申请号：US13196199

申请日：2011-08-02

Applicant: Adrian James Preston ,  David Ware

Inventor： Adrian James Preston ,  David Ware

IPC: G06F15/16

CPC classification number: H04L67/14 ,  H04L67/145 ,  H04L69/14 ,  H04L69/40

Abstract: Access to a device is controlled in a data processing network by receiving a first request from a client to connect to a device where the device is limited to a fixed number of client connections and connecting the client to an available client connection of the device if the fixed number of client connections on the device would not be exceeded by connecting the client. Access is further controlled by testing liveness of a current client connection on the device if the fixed number of client connections on the device would be exceeded by connecting the client and dropping the current client connection if the liveness testing indicates that the current client connection is not live.

Abstract translation: 通过从客户端接收到连接到设备被限制到固定数量的客户端连接并将客户机连接到设备的可用客户端连接的设备的数据处理网络中来控制对设备的访问，如果 连接客户端不会超过设备上固定数量的客户端连接。 如果活动测试表明当前客户端连接不是，通过连接客户端并删除当前客户端连接来超过设备上的客户端连接的固定数量，则可以通过测试设备上当前客户端连接的活动来进一步控制访问。 生活。

公开(公告)号：US20100008377A1

公开(公告)日：2010-01-14

申请号：US12169319

申请日：2008-07-08

Applicant: Srinivas Hasti ,  Michael J. Spreitzer ,  Graham D. Wallis ,  David Ware ,  Neil G.S. Young

Inventor： Srinivas Hasti ,  Michael J. Spreitzer ,  Graham D. Wallis ,  David Ware ,  Neil G.S. Young

IPC: H04L12/28

CPC classification number: H04L47/32 ,  H04L47/283 ,  H04L47/50 ,  H04L47/564 ,  H04L47/6245

Abstract: A system for managing inbound messages in a server complex including one or more message consumers. The system includes a server configured to receive the inbound messages from a first peripheral device and to transmit messages to one or more of the plurality of message consumers. The system also includes an inbound message queue coupled to the server, the inbound message queue configured to store inbound message and discard at least one message when an age of the message exceeds an expiration time.

Abstract translation: 用于管理服务器组合中的入站消息的系统，包括一个或多个消息消费者。 该系统包括被配置为从第一外围设备接收入站消息并将消息发送到多个消息消费者中的一个或多个的服务器。 系统还包括耦合到服务器的入站消息队列，入站消息队列被配置为存储入站消息，并且当消息的年龄超过到期时间时丢弃至少一个消息。

公开(公告)号：US20090313637A1

公开(公告)日：2009-12-17

申请号：US12138585

申请日：2008-06-13

Applicant: Tom Evans ,  Graham D. Wallis ,  David Ware ,  Christopher Wilkinson

Inventor： Tom Evans ,  Graham D. Wallis ,  David Ware ,  Christopher Wilkinson

IPC: G06F9/54

CPC classification number: G06F9/546 ,  G06F2209/548

Abstract: A method for preferential reply routing, the method includes: receiving a request-reply message from a requesting application; detecting there is a preferred partition of a reply queue managed locally to an application server to which the requesting application is connected; qualifying a name of a reply queue stored in the request-reply message so that the name refers to the local partition that is managed locally to the application server; determining whether the local partition is available; wherein in the event the local partition is available: storing a reply message in the local partition; and retrieving the reply message from the local partition in response to the requesting application.

Abstract translation: 一种用于优先回复路由的方法，所述方法包括：从请求应用接收请求应答消息; 检测到本地管理的应答队列的优选分区到请求应用连接到的应用服务器; 限定存储在请求 - 回复消息中的回复队列的名称，以便该名称引用本地管理到应用服务器的本地分区; 确定本地分区是否可用; 其中在本地分区可用的情况下：在本地分区中存储回复消息; 以及响应于所述请求应用从所述本地分区检索所述应答消息。

公开(公告)号：US06978400B2

公开(公告)日：2005-12-20

申请号：US10232251

申请日：2002-08-29

Applicant: Andrew I Hickson ,  Richard S Maxwell ,  David Ware

Inventor： Andrew I Hickson ,  Richard S Maxwell ,  David Ware

IPC: G06F11/00

CPC classification number: G06F17/30067 ,  G06F11/1471

Abstract: The invention relates to a method, apparatus and computer program for reducing the number of data elements checkpointed in a system having at least one data store where operations on said at least one data store are recorded in a log. A point in the log is recorded. The oldest data element in each of the least one data store is determined and it is then determined for each of the at least one data store whether a logged representation of the data store's oldest data element is more recent than the point recorded. Responsive to determining that a data store's logged representation is more recent than the point recorded, it is realised that it is not necessary to force data elements from that data store to disk if the point recorded is made the point of restart for that data store.

Abstract translation: 本发明涉及一种用于减少在具有至少一个数据存储器的系统中检查点的数量元素的数量的方法，装置和计算机程序，其中在所述至少一个数据存储器上的操作被记录在日志中。 记录日志中的一点。 确定至少一个数据存储器中的每一个中最早的数据元素，然后确定至少一个数据存储器中的每一个数据存储器的最早数据元素的记录表示是否比记录的点更近。 响应于确定数据存储的记录表示比记录的点更新，实现如果将记录的点作为该数据存储的重新启动点，则不需要将数据元素从该数据存储器强制到磁盘。

公开(公告)号：US06792604B1

公开(公告)日：2004-09-14

申请号：US09676994

申请日：2000-09-29

Applicant: Andrew Ian Hickson ,  Richard Scott Maxwell ,  Timothy Steven Raff ,  David Ware

Inventor： Andrew Ian Hickson ,  Richard Scott Maxwell ,  Timothy Steven Raff ,  David Ware

IPC: G06F946

CPC classification number: G06F9/524 ,  G06F9/546

Abstract: Provided are a method, computer program product and data processing apparatus for recovery from interprocess communication failures, the method comprising: in response to an initiator process requesting interprocess communication (IPC) with a responder process via an IPC link, recognizing if the initiator process does not have the expected write control of the IPC link and setting an indicator. A process other than the initiator process checks the indicator (such as after a timeout, or periodically) and, if the indicator has been set, notifies the initiator process to take control. This method avoids potential stalemate situations in which neither the initiator nor the responder process can take control, without reliance on mutex locks for every exchange of data and control.

Abstract translation: 提供了一种用于从进程间通信故障中恢复的方法，计算机程序产品和数据处理装置，所述方法包括：响应于通过IPC链路与响应者进程请求进程间通信（IPC）的发起者进程，识别发起者进程是否 没有IPC链接的预期写入控制和设置指标。 发起者进程之外的过程检查指示符（例如超时或周期性）之后，如果指示符已经设置，则通知发起者进程进行控制。 这种方法避免了潜在的僵持状态，既不要求发起者或响应者进程都可以控制，而不依赖互斥锁来进行数据和控制。

公开(公告)号：US06334151B1

公开(公告)日：2001-12-25

申请号：US09288988

申请日：1999-04-09

Applicant: Steven William Bolam ,  Brian Clive Homewood ,  Andrew Hickson ,  John Michael Knapman ,  David Ware

Inventor： Steven William Bolam ,  Brian Clive Homewood ,  Andrew Hickson ,  John Michael Knapman ,  David Ware

IPC: G06F15173

CPC classification number: G06Q40/04

Abstract: In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data from a subscriber application, a first broker data processing apparatus has: a unit for receiving a data message published on a first topic by a first publisher application; and a unit for forwarding the received published data message to a subscriber application which has requested, by entering subscription data, to receive a message on the first topic; wherein the first broker data processing apparatus sends a declaration to at least one other broker data processing apparatus of said plurality of broker data processing apparatuses declaring that the first broker data processing apparatus is the only broker data processing apparatus that is directly communicating with a publisher application that is publishing on the first topic.

Abstract translation: 在具有多个代理数据处理装置的发布/订阅数据处理代理网络中，每个代理数据处理装置具有用于直接从发布者应用接收已发布消息的输入和/或从订户应用接收订阅数据的第一代理数据处理装置， ：用于接收由第一发行商应用在第一主题上发布的数据消息的单元; 以及用于将接收到的已发布数据消息转发到已经通过输入订阅数据来请求接收关于第一主题的消息的订户应用的单元; 其中所述第一代理数据处理设备向所述多个代理数据处理设备中的至少一个其他代理数据处理设备发送声明，该代理数据处理设备宣布所述第一代理数据处理设备是与发布者应用程序直接通信的唯一代理数据处理设备 那就是出版第一个话题。

公开(公告)号：US6154781A

公开(公告)日：2000-11-28

申请号：US289011

申请日：1999-04-09

Applicant: Steven William Bolam ,  Brian Clive Homewood ,  Andrew Hickson ,  John Michael Knapman ,  David Ware

Inventor： Steven William Bolam ,  Brian Clive Homewood ,  Andrew Hickson ,  John Michael Knapman ,  David Ware

IPC: H04L29/08 ,  G06F13/38 ,  G06F15/17

CPC classification number: H04L67/26 ,  H04L67/2819 ,  H04L69/329 ,  Y10S707/99931 ,  Y10S707/99936

Abstract: In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data from a subscriber application, a first broker apparatus has: a software unit for receiving via said input subscription data from a subscriber application; a software unit for providing an acknowledgement to said subscriber application to acknowledge that the subscription data has been received; a software unit for propagating said subscription data to a group of other broker apparatuses; a software unit for determining whether said means for propagating has propagated said subscription data to the group of other broker apparatuses; and a software unit for receiving via said input an indication from said subscriber application that said acknowledgement should not be sent to the subscriber application until the means for determining has determined that said means for propagating has propagated said subscription data to the group of other broker apparatuses.

Abstract translation: 在具有多个代理数据处理装置的发布/订阅数据处理代理网络中，每个代理数据处理装置具有用于直接从发布者应用接收已发布消息的输入和/或从订户应用接收订阅数据，第一代理装置具有： 软件单元，用于经由所述输入订阅数据从订户应用接收; 软件单元，用于向所述用户应用提供确认已经接收到所述订阅数据的确认; 用于将所述订阅数据传播到一组其他代理设备的软件单元; 用于确定所述用于传播的装置是否已将所述订阅数据传播到所述其他代理设备的组的软件单元; 以及软件单元，用于经由所述输入从所述订户应用接收所述确认不应发送到订户应用的指示，直到所述用于确定的装置已经确定所述用于传播的装置已经将所述订阅数据传播到所述其他代理设备的组 。

公开(公告)号：US09146788B2

公开(公告)日：2015-09-29

申请号：US12049908

申请日：2008-03-17

Applicant: Malcolm D. Ayres ,  Andrew I. Hickson ,  Andrew M. Leonard ,  David Ware ,  Andrew J. Whitfield

Inventor： Malcolm D. Ayres ,  Andrew I. Hickson ,  Andrew M. Leonard ,  David Ware ,  Andrew J. Whitfield

IPC: G06F9/46 ,  G06F13/00 ,  G06F9/54

CPC classification number: G06F9/546

Abstract: Disclosed is a method for administering messages. In response to a determination that one or more consuming applications have failed to process the same message on a queue a predetermined number of times, the message is made unavailable to consuming applications. Responsive to determining that a predetermined number of messages have been made unavailable to consuming applications, one or more consuming applications are prevented from consuming messages from the queue.

Abstract translation: 公开了一种管理消息的方法。 响应于确定一个或多个消费应用程序未能在队列上预定次数处理相同的消息，使得该消息对消费应用不可用。 响应于确定已经使预定数量的消息对消费应用程序不可用，防止一个或多个消费应用程序消耗来自队列的消息。

公开(公告)号：US08589605B2

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

申请号：US12134366

申请日：2008-06-06

Applicant: Srinivas Hasti ,  Michael J. Spreitzer ,  Graham D. Wallis ,  David Ware ,  Neil G. S. Young

Inventor： Srinivas Hasti ,  Michael J. Spreitzer ,  Graham D. Wallis ,  David Ware ,  Neil G. S. Young

IPC: G06F5/14

CPC classification number: H04L47/564

Abstract: A system for managing inbound messages in a server complex including one or more message consumers. The system includes a server configured to receive the inbound messages from a first peripheral device and to transmit messages to one or more of the plurality of message consumers. The system also includes an inbound message queue coupled to the server, the inbound message queue configured to store inbound message until an age of any message stored on the inbound message queue exceeds a predetermined threshold.

Abstract translation: 用于管理服务器组合中的入站消息的系统，包括一个或多个消息消费者。 该系统包括被配置为从第一外围设备接收入站消息并将消息发送到多个消息消费者中的一个或多个的服务器。 系统还包括耦合到服务器的入站消息队列，入站消息队列被配置为存储入站消息，直到存储在入站消息队列上的任何消息的时间超过预定阈值。