International Business Machines Corporation

John J Duigenan

Cornell G Wright, Jr

Kenneth Wayne Borgendale

Foluso Olaiya Okunseinde

Nir Naaman

Hilary A Pike

Gidon Gershinsky

Eliezer Dekel

Alexander Krits

An indication of a configuration policy of a plurality of configuration policies is received at a feed adapter. The configuration policy of the plurality of configuration policies is selected based, at least in part, on the received indication of the configuration policy. The configuration policy of the plurality of configuration policies specifies a conversion rule from an input message format to an output message format using at least one conversion function of a plurality of conversion functions. The conversion rule specifies types of arguments that the at least one conversion function receives and returns. An application message having the input message format is received in the feed adapter. The feed adapter converts the application message having the input message format to an application message having the output message format according to the conversion rule specified by the configuration policy of the plurality of configuration policies.

Application message conversion using a feed adapter

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

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.

Referencing message elements in an application message in a messaging environment

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.

Growing community of inventors

New York, NY, United States of America

John J Duigenan