摘要:
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.
摘要:
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.
摘要:
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.
摘要:
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.
摘要:
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.
摘要:
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.
摘要:
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.
摘要:
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.
摘要:
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.
摘要:
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.