John 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… Show more

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. Show less

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… Show more

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. Show less

Methods, apparatus, and products are disclosed for generating a global system configuration for a financial market data system that include: establishing, by a configuration device, a component ruleset, the component ruleset specifying rules for component characteristics of one or more components capable of being used in financial market data systems; receiving, in the configuration device from a user through a graphical user interface, component characteristics of a specific component included… Show more

Methods, apparatus, and products are disclosed for generating a global system configuration for a financial market data system that include: establishing, by a configuration device, a component ruleset, the component ruleset specifying rules for component characteristics of one or more components capable of being used in financial market data systems; receiving, in the configuration device from a user through a graphical user interface, component characteristics of a specific component included in a financial market data system; storing, by the configuration device, the received component characteristics of the specific component in a global system configuration for the financial market data system; determining, by the configuration device, whether the received component characteristics satisfy the component ruleset; and supplementing, by the configuration device, the received component characteristics stored in the global system configuration with additional component characteristics in dependence upon the component ruleset if the received component characteristics do not satisfy the component ruleset.
Show less

Methods, apparatus, and products are disclose for application message conversion using a feed adapter that include providing a feed adapter capable of application message conversion, the feed adapter comprising a plurality of conversion functions, each conversion function capable of converting data from one format to another format; establishing, on the feed adapter, a configuration policy that specifies a conversion rule from an input message format to an output message format using at least… Show more

Methods, apparatus, and products are disclose for application message conversion using a feed adapter that include providing a feed adapter capable of application message conversion, the feed adapter comprising a plurality of conversion functions, each conversion function capable of converting data from one format to another format; establishing, on the feed adapter, a configuration policy that specifies a conversion rule from an input message format to an output message format using at least one of the conversion functions; receiving, in the feed adapter, an application message having the input message format; and converting, by the feed adapter, the application message having the input message format to an application message having the output message format according to the conversion rule of the configuration policy. Show less

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… Show more

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. Show less

A multicast host for communicating information published about any one of a set of topics to one or more authorised subscribers to those topics, the set of topics being partitioned into one or more partition elements, each partition element having a partition element encryption key associated therewith, wherein each of the one or more partition elements is a disjoint proper subset of the set of topics, the host comprising: means for receiving information relating to a topic; means for… Show more

A multicast host for communicating information published about any one of a set of topics to one or more authorised subscribers to those topics, the set of topics being partitioned into one or more partition elements, each partition element having a partition element encryption key associated therewith, wherein each of the one or more partition elements is a disjoint proper subset of the set of topics, the host comprising: means for receiving information relating to a topic; means for determining a partition element for the topic; means for retrieving a partition element encryption key associated with the partition element; means for encrypting the information with the retrieved partition element encryption key; and means for communicating the information to the one or more authorised subscribers. Show less

Methods, apparatus, and products are disclosed for establishing a financial market data component in a financial market data system that include: retrieving, by a configuration module from a configuration repository, at least a portion of a global system configuration for a financial market data system, the financial market data system comprising a plurality of financial market data components; identifying, by the configuration module in dependence upon the retrieved portion of the global… Show more

Methods, apparatus, and products are disclosed for establishing a financial market data component in a financial market data system that include: retrieving, by a configuration module from a configuration repository, at least a portion of a global system configuration for a financial market data system, the financial market data system comprising a plurality of financial market data components; identifying, by the configuration module in dependence upon the retrieved portion of the global system configuration, component characteristics of a particular financial market data component in the financial market data system, the component characteristics further comprise a system identifier, a component functional group identifier, and a component business group identifier; and deploying, by the configuration module, the financial market data component in the financial market data system in dependence upon the component characteristics. Show less

Methods, systems, and products are disclosed for terminating an application message subscription that include: receiving, by messaging middleware of a subscribing client device, application messages having one or more message topics on one or more message streams from one or more message transmitting devices; receiving, by the messaging middleware from a stream administration server, a subscription termination message specifying a particular message topic for application messages that the… Show more

Methods, systems, and products are disclosed for terminating an application message subscription that include: receiving, by messaging middleware of a subscribing client device, application messages having one or more message topics on one or more message streams from one or more message transmitting devices; receiving, by the messaging middleware from a stream administration server, a subscription termination message specifying a particular message topic for application messages that the subscription client device is no longer authorized to receive; and ceasing, by the messaging middleware, to provide the received application messages having the particular message topic to an application on the subscribing client device, including providing the received application messages having other message topics to the application.
Show less

Methods, systems, and products are disclosed for application message subscription tracking in a high speed, low latency data communications environment that includes: receiving, by a stream administration server from a subscribing client device, a subscription initiation request, the subscription initiation request specifying a message topic, the message topic specifying application messages for transmission to the subscribing client device from a message transmitting device; brokering, by the… Show more

Methods, systems, and products are disclosed for application message subscription tracking in a high speed, low latency data communications environment that includes: receiving, by a stream administration server from a subscribing client device, a subscription initiation request, the subscription initiation request specifying a message topic, the message topic specifying application messages for transmission to the subscribing client device from a message transmitting device; brokering, by the stream administration server, establishment of a message stream that provides the application messages for the specified message topic from the message transmitting device to the subscribing client device; and updating, by the stream administration server, a client subscription repository for monitoring application message subscriptions in dependence upon the subscription initiation request. Show less

Methods, apparatus, and products are disclosed for dispatching a message request to a service provider in a messaging environment that include: establishing, on a message administration device, a plurality of lookup tables for mapping request types to service providers; receiving, in the message administration device from a message requesting device, a message request of one of the request types; identifying, by the message administration device, the service provider for processing the message… Show more

Methods, apparatus, and products are disclosed for dispatching a message request to a service provider in a messaging environment that include: establishing, on a message administration device, a plurality of lookup tables for mapping request types to service providers; receiving, in the message administration device from a message requesting device, a message request of one of the request types; identifying, by the message administration device, the service provider for processing the message request in dependence upon the message request and the plurality of lookup tables; and providing, by the message administration device, the message request to the identified service provider. Show less

Methods, apparatus, and products are disclosed for generating a global system configuration for a financial market data system that include: establishing, by a configuration device, a component ruleset, the component ruleset specifying rules for component characteristics of one or more components capable of being used in financial market data systems; receiving, in the configuration device from a user through a graphical user interface, component characteristics of a specific component included… Show more

Methods, apparatus, and products are disclosed for generating a global system configuration for a financial market data system that include: establishing, by a configuration device, a component ruleset, the component ruleset specifying rules for component characteristics of one or more components capable of being used in financial market data systems; receiving, in the configuration device from a user through a graphical user interface, component characteristics of a specific component included in a financial market data system; storing, by the configuration device, the received component characteristics of the specific component in a global system configuration for the financial market data system; determining, by the configuration device, whether the received component characteristics satisfy the component ruleset; and supplementing, by the configuration device, the received component characteristics stored in the global system configuration with additional component characteristics in dependence upon the component ruleset if the received component characteristics do not satisfy the component ruleset. Show less

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… Show more

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. Show less

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… Show more

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. Show less