International Business Machines Corporation

Alexander Krits

Nir Naaman

Gidon Gershinsky

Eliezer Dekel

Cornell G Wright, Jr

Hilary A Pike

Foluso Olaiya Okunseinde

John J Duigenan

Avraham Harpaz

Kenneth Wayne Borgendale

Benjamin Mandler

Idan Zach

James William Stopyro

Alan Jay Wecker

Roman Vitenberg

Cornell Wright

Hilary Alison Pike

Cornell Wright Jr

John Justin Duigenan

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.

Synchronizing an active feed adapter and a backup feed adapter in a high speed, low latency data communications environment

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.

Reliable messaging using redundant message streams in a high speed, low latency data communications environment

A group communication service maintains synchronization limiting the group to the processing entities that receive a plurality of source message streams from sources outside the group and transmit delivery message streams to destinations that are outside the group. Synchronization of message ordering and other state synchronization directives are communicated from a leader exclusively to other group members. Once having declared themselves to be synchronized and active by a reply protocol message, which is an opaque object and is interpreted by an application layer, the processing entities independently process the source message streams in accordance with the order specified in the directives, without requiring additional sequencing information from another processing entity.

Group communication system achieving efficient total order and state synchronization in a multi-tier environment

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.

Synchronization of message stream in a multi-tier messaging system

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.

Methods and systems are provided in a group communication system for dynamically changing a version of a group communication protocol from a first version to a second version transparently to external sources and destinations. The system accommodates newly joining members that can only support versions of the protocol other than the version currently in use without interruption in service. Similarly, the system can upgrade its operating version of the group communication protocol to improve performance when a member having relatively low capabilities exits the group.

Protocol negotiation for a group communication system

Growing community of inventors

Haifa, Israel

Alexander Krits