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

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

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

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

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

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

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

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

公开(公告)号：US20080244017A1

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

申请号：US11728850

申请日：2007-03-27

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

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

IPC分类号： 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.

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

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

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

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

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

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

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