公开(公告)号：US20080141275A1

公开(公告)日：2008-06-12

申请号：US11609696

申请日：2006-12-12

申请人： Kenneth W. Borgendale ,  Gidon Gershinskey ,  Nir Naaman ,  Foluso O. Okunseinde ,  Cornell G. Wright

发明人： Kenneth W. Borgendale ,  Gidon Gershinskey ,  Nir Naaman ,  Foluso O. Okunseinde ,  Cornell G. Wright

IPC分类号： G06F3/00

CPC分类号： G06F9/542 ,  G06F9/541 ,  G06F2209/546

摘要： Methods, systems, and products are disclosed for filtering application messages in a high speed, low latency data communications environment that include: establishing, in a transport engine of a subscribing client device, a transport layer constraint on application messages to be received by the subscribing client device from a feed adapter; receiving, in the transport engine of the subscribing client device from the feed adapter, an application message; determining, by the transport engine of the subscribing client device, whether contents of the application message satisfy the transport layer constraint; and administering the application message, by the transport engine of the subscribing client device, in dependence upon whether the contents of the application message satisfy the transport layer constraint.

摘要翻译： 公开了用于在高速，低延迟的数据通信环境中过滤应用消息的方法，系统和产品，其包括：在订阅客户端设备的传输引擎中建立要由订阅的应用消息接收的应用消息的传输层约束 客户端设备从供应适配器; 在所述订阅客户端设备的所述传送引擎中从所述馈送适配器接收应用消息; 由订阅客户端设备的传输引擎确定应用消息的内容是否满足传输层约束; 以及由订阅客户端设备的传输引擎根据应用消息的内容是否满足传输层约束来管理应用消息。

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

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

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

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

公开(公告)号：US20080141276A1

公开(公告)日：2008-06-12

申请号：US11609708

申请日：2006-12-12

申请人： Kenneth W. Borgendale ,  John J. Duigenan ,  Foluso O. Okunseinde ,  Cornell G. Wright

发明人： Kenneth W. Borgendale ,  John J. Duigenan ,  Foluso O. Okunseinde ,  Cornell G. Wright

IPC分类号： G06F3/00

CPC分类号： G06F9/546 ,  G06F9/541

摘要： Methods, systems, and products are disclosed for referencing message elements in an application message in a messaging environment that include: establishing a message model on a computer, the message model comprising message element specifications that each specify a message element for storing data in the application messages, each message element specification comprising element characteristics; creating, by a messaging module on the computer in dependence upon the message model, a message element designator map that maps a separate message element designator to each message element specified by the message model; receiving, in the messaging module from a requesting module, a request for an element designator for a specific message element identified by the element characteristics for the specific message element; and providing, by the messaging module to the requesting module, the requested element designator in dependence upon the message element designator map and the element characteristics for the specific message element.

摘要翻译： 公开了用于在消息传递环境中的应用消息中引用消息元素的方法，系统和产品，其包括：在计算机上建立消息模型，所述消息模型包括各自指定消息元素以在应用中存储数据的消息元素规范 消息，每个消息元素规范包括元素特征; 通过计算机上的消息模块根据消息模型创建将单独的消息元素指示符映射到由消息模型指定的每个消息元素的消息元素指示符映射; 在所述消息模块中从请求模块接收对由所述特定消息元素的元素特征标识的特定消息元素的元素指示符的请求; 以及根据所述消息元素指示符图和所述特定消息元素的元素特征，由所述消息模块向所述请求模块提供所请求的元素指示符。

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

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

公开(公告)号：US08327381B2

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

申请号：US11609708

申请日：2006-12-12

申请人： Kenneth W. Borgendale ,  John J. Duigenan ,  Foluso O. Okunseinde ,  Cornell G. Wright, Jr.

发明人： Kenneth W. Borgendale ,  John J. Duigenan ,  Foluso O. Okunseinde ,  Cornell G. Wright, Jr.

IPC分类号： G06F17/30

CPC分类号： G06F9/546 ,  G06F9/541

摘要： Methods, systems, and products are disclosed for referencing message elements in an application message in a messaging environment that include: establishing a message model on a computer, the message model comprising message element specifications that each specify a message element for storing data in the application messages, each message element specification comprising element characteristics; creating, by a messaging module on the computer in dependence upon the message model, a message element designator map that maps a separate message element designator to each message element specified by the message model; receiving, in the messaging module from a requesting module, a request for an element designator for a specific message element identified by the element characteristics for the specific message element; and providing, by the messaging module to the requesting module, the requested element designator in dependence upon the message element designator map and the element characteristics for the specific message element.

摘要翻译： 公开了用于在消息传递环境中的应用消息中引用消息元素的方法，系统和产品，其包括：在计算机上建立消息模型，所述消息模型包括各自指定消息元素以在应用中存储数据的消息元素规范 消息，每个消息元素规范包括元素特征; 通过计算机上的消息模块根据消息模型创建将单独的消息元素指示符映射到由消息模型指定的每个消息元素的消息元素指示符映射; 在所述消息模块中从请求模块接收对由所述特定消息元素的元素特征标识的特定消息元素的元素指示符的请求; 以及根据所述消息元素指示符映射和所述特定消息元素的元素特征，由所述消息模块向所述请求模块提供所请求的元素指示符。

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

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