公开(公告)号：US20070300234A1

公开(公告)日：2007-12-27

申请号：US11426819

申请日：2006-06-27

申请人： Eliezer Dekel ,  John J. Duigenan ,  Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Yoav Tock ,  Cornell G. Wright

发明人： Eliezer Dekel ,  John J. Duigenan ,  Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Yoav Tock ,  Cornell G. Wright

IPC分类号： G06F9/46

CPC分类号： G06F9/546 ,  G06Q10/107 ,  H04L12/1868 ,  H04L69/40

摘要： Selecting application messages from redundant feed adapters for application-level data processing in a high speed, low latency data communications environment, including brokering establishment of an active message stream to a subscribing client device from an active feed adapter; brokering establishment of a backup message stream to the subscribing client device from a backup feed adapter; receiving active transport packets in a transport engine of the subscribing client device from the active feed adapter; receiving and buffering backup transport packets; identifying a missing active transport packet; determining whether a corresponding backup transport packet for the missing active transport packet has been received from the backup transport adapter; and replacing the missing active transport packet with the corresponding backup transport packet for further data processing if the corresponding backup transport packet for the missing active transport packet has been received.

摘要翻译： 从冗余馈送适配器中选择应用消息以在高速，低延迟数据通信环境中进行应用级数据处理，包括从活动馈送适配器向订阅客户端设备建立活动消息流; 从备用馈送适配器代理建立备用消息流到订阅客户端设备; 在所述订阅客户端设备的传输引擎中从所述活动馈送适配器接收活动传输分组; 接收和缓冲备份传输数据包; 识别丢失的活动传输分组; 确定是否已经从备用传输适配器接收到用于丢失的活动传输分组的对应的备份传输分组; 并且如果已经接收到用于丢失的活动传输分组的对应的备份传输分组，则用相应的备份传输分组替换丢失的活动传输分组用于进一步的数据处理。

公开(公告)号：US08676876B2

公开(公告)日：2014-03-18

申请号：US11426864

申请日：2006-06-27

申请人： Eliezer Dekel ,  John J. Duigenan ,  Gidon Gershinsky ,  Alexander Krits ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Cornell G. Wright, Jr.

发明人： Eliezer Dekel ,  John J. Duigenan ,  Gidon Gershinsky ,  Alexander Krits ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Cornell G. Wright, Jr.

IPC分类号： G06F11/20

CPC分类号： H04L51/04 ,  H04L51/066

摘要： Methods, apparatus, and products are disclosed for synchronizing an active feed adapter and a backup feed adapter in a high speed, low latency data communications environment that include brokering, by a stream administration server, establishment of an active message stream to a subscribing client device from an active feed adapter, the active message stream capable of communicating active application messages; brokering, by the server, establishment of a backup message stream to the client device from a backup feed adapter, the backup message stream capable of communicating backup application messages; receiving an active feed adapter state in backup messaging middleware of the backup adapter from active messaging middleware of the active adapter; determining, by the backup feed adapter, whether a backup feed adapter state is synchronized with the active feed adapter state; and administering, by the backup feed adapter, operation of the backup adapter in dependence upon the determining.

摘要翻译： 公开了用于在高速，低延迟的数据通信环境中同步活动馈送适配器和备用馈送适配器的方法，装置和产品，其包括流管理服务器向订阅客户端设备建立活动消息流 来自活动馈送适配器的能够传送活动应用消息的活动消息流; 通过服务器代理从备份馈送适配器建立到客户端设备的备份消息流，该备份消息流能够传送备份应用消息; 从活动适配器的活动消息传递中间件接收备份适配器的备份消息中间件中的活动馈送适配器状态; 由备份馈送适配器确定备份馈送适配器状态是否与活动馈送适配器状态同步; 以及由所述备份馈送适配器根据所述确定来管理所述备用适配器的操作。

公开(公告)号：US07917912B2

公开(公告)日：2011-03-29

申请号：US11728850

申请日：2007-03-27

申请人： Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Cornell G. Wright, Jr.

发明人： Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Cornell G. Wright, Jr.

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

CPC分类号： H04L63/0227 ,  H04L67/327

摘要： Methods, systems, and products are disclosed for filtering application messages in a high speed, low latency data communications environment that include: receiving an application message in a transport engine of a message receiving device from a message transmitting device, the application message having a message contents label and a collision indicator, the message contents label representing contents of the application message, the collision indicator specifying whether the message contents label represents different contents in at least one other application message; determining, by the transport engine, whether contents of the application message satisfy a transport layer constraint in dependence upon the message contents label; providing, by the transport engine, the application message and the collision indicator to messaging middleware of the message receiving device if the contents of the application message satisfy the transport layer constraint; and administering the application message, by the messaging middleware, in dependence upon the collision indicator.

摘要翻译： 公开了用于在高速，低延迟的数据通信环境中过滤应用消息的方法，系统和产品，其包括：从消息发送设备在消息接收设备的传输引擎中接收应用消息，所述应用消息具有消息 内容标签和冲突指示符，所述消息内容标签表示所述应用消息的内容，所述冲突指示符指定所述消息内容标签是否表示至少一个其他应用消息中的不同内容; 由所述传输引擎确定所述应用消息的内容是否根据所述消息内容标签满足传输层约束; 如果应用消息的内容满足传输层约束，则通过传输引擎将应用消息和冲突指示符提供给消息接收设备的消息中间件; 以及由所述消息收发中间件根据所述冲突指示器来管理所述应用消息。

公开(公告)号：US20070300233A1

公开(公告)日：2007-12-27

申请号：US11426789

申请日：2006-06-27

申请人： KULVIR S BHOGAL ,  Paul D. Lewis ,  Foluso O. Okunseinde ,  Ramanujam Ravisankar ,  Cornell G. Wright

发明人： KULVIR S BHOGAL ,  Paul D. Lewis ,  Foluso O. Okunseinde ,  Ramanujam Ravisankar ,  Cornell G. Wright

IPC分类号： G06F9/46

CPC分类号： G06F9/546 ,  G06F2209/547 ,  H04L63/08

摘要： Methods, apparatus, and products are disclosed for computer data communications in a high speed, low latency data communications environment that include: brokering, by a stream administration server, establishment of a message stream from a contributing client device to a feed adapter, including authenticating the contributing client device, authorizing the contributing client device to send messages to the feed adapter on the message stream, and establishing in messaging middleware of the contributing client device a set of constraints on messages to be transmitted from the contributing client device to the feed adapter; receiving, in the messaging middleware of the contributing client device from an application of the contributing client device, a message for transmission to the feed adapter on the message stream; determining, by the messaging middleware, whether contents of the message satisfy the constraints; and administering the message, by the messaging middleware, in dependence upon whether the message satisfies the constraints.

摘要翻译： 公开了用于高速，低延迟数据通信环境中的计算机数据通信的方法，装置和产品，其包括：由流管理服务器代理建立从贡献客户端设备到馈送适配器的消息流，包括认证 贡献客户端设备，授权贡献客户端设备向消息流上的馈送适配器发送消息，以及在贡献客户端设备的消息中间件中建立要从贡献客户端设备发送到馈送适配器的消息的一组约束 ; 在来自贡献客户端设备的应用的贡献客户端设备的消息传送中间件中接收消息流上传送给馈送适配器的消息; 通过消息中间件确定消息的内容是否满足约束; 以及由所述消息收发中间件根据所述消息是否满足所述约束来管理所述消息。

公开(公告)号：US20080104266A1

公开(公告)日：2008-05-01

申请号：US11586076

申请日：2006-10-25

申请人： Eliezer Dekel ,  John J. Duigenan ,  Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Yoav Tock ,  Cornell G. Weight

发明人： Eliezer Dekel ,  John J. Duigenan ,  Gidon Gershinsky ,  Avraham Harpaz ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Yoav Tock ,  Cornell G. Weight

IPC分类号： G06F15/16

CPC分类号： H04L51/30

摘要： Methods, apparatus, and products are disclosed for reliable messaging using message streams in a high speed, low latency data communications environment that include: receiving, in a transport engine of a message receiving device from an active message sending device, active transport packets on an active message stream established from the active message sending device to the message receiving device, the active message sending device encapsulating active application messages in the active transport packets; identifying, by the transport engine, a missing active application message from the active message sending device; and requesting, by the transport engine from a backup message sending device, transmission of a backup application message that corresponds to the missing active application message, the backup message sending device encapsulating backup application messages in backup transport packets for transmission on a backup message stream, each backup application message representing a duplicate of a corresponding active application message.

摘要翻译： 公开了用于在高速，低延迟数据通信环境中使用消息流的可靠消息的方法，装置和产品，包括：在来自活动消息发送设备的消息接收设备的传输引擎中，在主动传输分组 主动消息流从活动消息发送设备建立到消息接收设备，活动消息发送设备将活动应用消息封装在活动传输分组中; 由所述传输引擎识别来自所述活动消息发送设备的丢失的活动应用消息; 并且通过传输引擎从备份消息发送设备发送与所述丢失的活动应用消息相对应的备份应用消息的传输，所述备份消息发送设备将备份应用消息封装在备份传输分组中以便在备份消息流上传输， 每个备份应用程序消息表示对应的活动应用程序消息的副本。

公开(公告)号：US08296778B2

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

申请号：US11426789

申请日：2006-06-27

申请人： Kulvir S. Bhogal ,  Paul D. Lewis ,  Foluso O. Okunseinde ,  Ramanujam Ravisankar ,  Cornell G. Wright, Jr.

发明人： Kulvir S. Bhogal ,  Paul D. Lewis ,  Foluso O. Okunseinde ,  Ramanujam Ravisankar ,  Cornell G. Wright, Jr.

IPC分类号： G06F3/00

CPC分类号： G06F9/546 ,  G06F2209/547 ,  H04L63/08

摘要： Methods, apparatus, and products are disclosed for computer data communications in a high speed, low latency data communications environment that include: brokering, by a stream administration server, establishment of a message stream from a contributing client device to a feed adapter, including authenticating the contributing client device, authorizing the contributing client device to send messages to the feed adapter on the message stream, and establishing in messaging middleware of the contributing client device a set of constraints on messages to be transmitted from the contributing client device to the feed adapter; receiving, in the messaging middleware of the contributing client device from an application of the contributing client device, a message for transmission to the feed adapter on the message stream; determining, by the messaging middleware, whether contents of the message satisfy the constraints; and administering the message, by the messaging middleware, in dependence upon whether the message satisfies the constraints.

摘要翻译： 公开了用于高速，低延迟数据通信环境中的计算机数据通信的方法，装置和产品，其包括：由流管理服务器代理建立从贡献客户端设备到馈送适配器的消息流，包括认证 贡献客户端设备，授权贡献客户端设备向消息流上的馈送适配器发送消息，以及在贡献客户端设备的消息中间件中建立要从贡献客户端设备发送到馈送适配器的消息的一组约束 ; 在来自贡献客户端设备的应用的贡献客户端设备的消息传送中间件中接收消息流上传送给馈送适配器的消息; 通过消息中间件确定消息的内容是否满足约束; 以及由所述消息收发中间件根据所述消息是否满足所述约束来管理所述消息。