公开(公告)号：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.

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

公开(公告)号：US20070300235A1

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

申请号：US11426857

申请日：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 ,  H04L9/32

CPC分类号： H04L69/326

摘要： Methods, apparatus, and products are disclosed for reliable messaging using a message stream 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; receiving, in a transport engine of the subscribing client device from the active feed adapter on an active message stream, active application messages encapsulated in active transport packets; receiving, by the transport engine from the active feed adapter, an active transport packet containing an active mapping; identifying, by the transport engine in dependence upon active sequence numbers, a missing active transport packet; identifying, by the transport engine, missing active application messages of the missing active transport packet in dependence upon the active mapping; and requesting, by the transport engine, transmission of the missing active application messages from the active feed adapter.

摘要翻译： 公开了方法，装置和产品，用于使用消息流在高速，低延迟的数据通信环境中的可靠消息传递，其包括由流管理服务器从活动馈送向订阅客户端设备建立活动消息流 适配器; 在活动消息流中从主动馈送适配器在订阅客户端设备的传输引擎中接收封装在活动传输分组中的活动应用消息; 通过传输引擎从主动馈送适配器接收包含活动映射的主动传输分组; 通过传输引擎根据活动序列号识别丢失的活动传输分组; 由传输引擎根据主动映射来识别丢失的活动传输分组的活动应用消息; 并且由传输引擎请求从活动馈送适配器传输丢失的活动应用消息。

公开(公告)号：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.

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

公开(公告)号：US20080010487A1

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

申请号：US11426864

申请日：2006-06-27

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

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

IPC分类号： G06F11/00

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.

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

公开(公告)号：US08549168B2

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

申请号：US13343553

申请日：2012-01-04

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

发明人： Kenneth W. Borgendale ,  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分类号： H04L67/26 ,  G06F9/546 ,  H04L12/1859

摘要： A method includes receiving active application messages that are part of an active message stream in a subscribing client device from an active feed adapter. Each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number. The method includes receiving, in response to a failover from the active feed adapter to a backup feed adapter, backup application messages in the subscribing client device from the backup feed adapter. Each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number. The method includes administering, by the subscribing client device, the backup application messages in dependence upon the active stream source identifier, the active stream source sequence number, the backup stream source identifier, and the backup stream source sequence number.

摘要翻译： 一种方法包括从主动馈送适配器接收作为订阅客户端设备中的活动消息流的一部分的活动应用消息。 每个活动应用消息的特征在于活动源流标识符，活动源流序列号和活动消息序列号。 该方法包括响应于从主动馈送适配器到备份馈送适配器的故障转移，从备用馈送适配器在订阅客户端设备中备份应用程序消息。 每个备份应用消息的特征在于备份源流标识符，备份源流序列号和备份消息序列号。 该方法包括根据活动流源标识符，活动流源序列号，备份流源标识符和备份流源序列号，由订阅客户端设备管理备份应用消息。

公开(公告)号：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.

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

公开(公告)号：US08122144B2

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

申请号：US11426849

申请日：2006-06-27

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

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

IPC分类号： G06F15/16 ,  H04L12/26

CPC分类号： H04L67/26 ,  G06F9/546 ,  H04L12/1859

摘要： Methods, apparatus, and products are disclosed for reliable messaging using redundant message streams 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 subscribing client device from a backup feed adapter, the backup message stream capable of communicating backup application messages representing duplicates of the active messages; receiving the active messages in messaging middleware of the subscribing client device; receiving, in response to a failover, the backup messages in the messaging middleware; and administering, by the messaging middleware, the backup messages in dependence upon an active stream source identifier, an active stream source sequence number, a backup stream source identifier, and a backup stream source sequence number.

摘要翻译： 公开了用于在高速，低延迟数据通信环境中使用冗余消息流的可靠消息的方法，装置和产品，其包括流管理服务器从活动馈送向订阅客户端设备建立活动消息流 适配器，能够传送活动应用消息的活动消息流; 由服务器代理从备份馈送适配器建立到订阅客户端设备的备份消息流，该备份消息流能够传送表示活动消息的重复的备份应用消息; 在订阅的客户端设备的消息中间件中接收活动消息; 响应于故障转移接收消息中间件中的备份消息; 以及根据活动流源标识符，活动流源序列号，备份流源标识符和备份流源序列号，通过消息中间件管理备份消息。

公开(公告)号：US20070299973A1

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

申请号：US11426849

申请日：2006-06-27

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

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

IPC分类号： G06F15/16

CPC分类号： H04L67/26 ,  G06F9/546 ,  H04L12/1859

摘要： Methods, apparatus, and products are disclosed for reliable messaging using redundant message streams 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 subscribing client device from a backup feed adapter, the backup message stream capable of communicating backup application messages representing duplicates of the active messages; receiving the active messages in messaging middleware of the subscribing client device; receiving, in response to a failover, the backup messages in the messaging middleware; and administering, by the messaging middleware, the backup messages in dependence upon an active stream source identifier, an active stream source sequence number, a backup stream source identifier, and a backup stream source sequence number.

摘要翻译： 公开了用于在高速，低延迟数据通信环境中使用冗余消息流的可靠消息的方法，装置和产品，其包括流管理服务器从活动馈送向订阅客户端设备建立活动消息流 适配器，能够传送活动应用消息的活动消息流; 由服务器代理从备份馈送适配器建立到订阅客户端设备的备份消息流，该备份消息流能够传送表示活动消息的重复的备份应用消息; 在订阅的客户端设备的消息中间件中接收活动消息; 响应于故障转移接收消息中间件中的备份消息; 以及根据活动流源标识符，活动流源序列号，备份流源标识符和备份流源序列号，通过消息中间件管理备份消息。

公开(公告)号：US20120110372A1

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

申请号：US13343553

申请日：2012-01-04

申请人： Kenneth W. Borgendale ,  Eliezer Dekel ,  John L. Duigenan ,  Gidon Gershinsky ,  Alexander Krits ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Cornell G. Wright, JR.

发明人： Kenneth W. Borgendale ,  Eliezer Dekel ,  John L. Duigenan ,  Gidon Gershinsky ,  Alexander Krits ,  Nir Naaman ,  Foluso O. Okunseinde ,  Hilary A. Pike ,  Cornell G. Wright, JR.

IPC分类号： G06F11/20

CPC分类号： H04L67/26 ,  G06F9/546 ,  H04L12/1859

摘要： A method includes receiving active application messages that are part of an active message stream in a subscribing client device from an active feed adapter. Each active application message is characterized by an active source stream identifier, an active source stream sequence number, and an active message sequence number. The method includes receiving, in response to a failover from the active feed adapter to a backup feed adapter, backup application messages in the subscribing client device from the backup feed adapter. Each backup application message is characterized by a backup source stream identifier, a backup source stream sequence number, and a backup message sequence number. The method includes administering, by the subscribing client device, the backup application messages in dependence upon the active stream source identifier, the active stream source sequence number, the backup stream source identifier, and the backup stream source sequence number.

摘要翻译： 一种方法包括从主动馈送适配器接收作为订阅客户端设备中的活动消息流的一部分的活动应用消息。 每个活动应用消息的特征在于活动源流标识符，活动源流序列号和活动消息序列号。 该方法包括响应于从主动馈送适配器到备份馈送适配器的故障转移，从备用馈送适配器在订阅客户端设备中备份应用程序消息。 每个备份应用消息的特征在于备份源流标识符，备份源流序列号和备份消息序列号。 该方法包括根据活动流源标识符，活动流源序列号，备份流源标识符和备份流源序列号，由订阅客户端设备管理备份应用消息。

公开(公告)号：US08218549B2

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

申请号：US11764232

申请日：2007-06-18

申请人： Eliezer Dekel ,  Gidon Gershinsky ,  Avraham Harpaz ,  Alexander Krits ,  Benjamin Mandler ,  Nir Naaman

发明人： Eliezer Dekel ,  Gidon Gershinsky ,  Avraham Harpaz ,  Alexander Krits ,  Benjamin Mandler ,  Nir Naaman

IPC分类号： H04L12/28 ,  H04L12/56

CPC分类号： H04L12/1881 ,  H04L51/34

摘要： A group communication service is adapted for multi-point to multi-point communication. Identical message streams are received by a tier of processing servers from a tier of sources. The processing servers deliver the message streams to a tier of destinations. The group communication service enables the processing servers to deal with newly added message streams and deleted message streams while preserving total ordering.

摘要翻译： 组通信服务适用于多点到多点通信。 相同消息流由一层处理服务器从源层接收。 处理服务器将消息流传递到目的地层。 组通信服务使得处理服务器能够处理新添加的消息流和删除的消息流，同时保持总的排序。