International Business Machines Corporation

Google Inc.

Foluso Olaiya Okunseinde

Cornell G Wright, Jr

Tyron Jerrod Stading

Michael A Gilfix

Nir Naaman

Gidon Gershinsky

John J Duigenan

Scott Lee Winters

Jerry Walter Malcolm

Paul Stuart Williamson

Hilary A Pike

Kenneth Wayne Borgendale

Eliezer Dekel

Alexander Krits

Kulvir Singh Bhogal

Paul D Lewis

Ramanujam Ravisankar

John Justin Duigenan

Cornell Wright

Hilary Alison Pike

Avraham Harpaz

Michael Gilfix

A method includes issuing a request, from an application of a contributing client device to a stream administration server, to contribute messages from the application to a feed adapter within a data communication environment via a message stream which bypasses the stream administration server. The feed adapter is coupled to a feed source via a feed adapter input stream and to at least one subscribing device via a feed adapter output stream. The feed source is separate from the contributing client device. The feed adapter input stream is separate from the message stream. The method includes receiving, in response to the request and an authentication of the contributing client device. A set of constraints on messages is to be transmitted from the contributing client device to the feed adapter.

Computer data communications in a high speed, low latency data communications environment

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 computer data communications in a high speed, low latency data communications environment that include: brokering, by a stream administration server, establishment of a message stream from a contributing client device to a feed adapter, including authenticating the contributing client device, authorizing the contributing client device to send messages to the feed adapter on the message stream, and establishing in messaging middleware of the contributing client device a set of constraints on messages to be transmitted from the contributing client device to the feed adapter; receiving, in the messaging middleware of the contributing client device from an application of the contributing client device, a message for transmission to the feed adapter on the message stream; determining, by the messaging middleware, whether contents of the message satisfy the constraints; and administering the message, by the messaging middleware, in dependence upon whether the message satisfies the constraints.

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, 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.

Filtering application messages in a high speed, low latency data communications environment

Systems and methods of application integration, including constructing an application integration adapter in dependence upon a profile including data describing the adapter, receiving instructions to alter the adapter, and altering the adapter in dependence upon the instructions. Exemplary embodiments of the invention include communicating integration messages among applications through the adapter as altered. In typical embodiments, receiving instructions to alter the adapter includes detecting changes in the adapter profile. In such embodiments, detecting changes in the adapter profile includes creating a copy of the profile, and periodically comparing the profile and the copy. In other exemplary embodiments, receiving instructions to alter the adapter includes receiving from an application an administrative integration message bearing the instructions to alter the adapter. In such embodiments, altering the adapter in dependence upon the instructions includes updating the profile.

Dynamic data-driven application integration adapters

Provided is an apparatus and method for detecting fraudulent passwords so that computer break-in attempts can be distinguished from authorized users incorrectly entering their passwords. An actual password is mapped against a computer keyboard and the resultant data is stored in memory. The profile of an entered password is compared to the stored profile. If the profile of the entered password differs significantly from the stored profile, then the login attempt is flagged as an attempted intrusion. In one embodiment of the current invention, passwords are mapped according to the distance subsequent keystrokes are from each other. Different embodiments may have different mapping schemes. For example, mapping data may correspond to statistical data that corresponds to the likelihood that a particular character is typed by mistake when another character is intended.

Method and apparatus for detecting password attacks using modeling techniques

A tool is provided for testing integration logic in a hub-and-spoke integration scheme. The testing tool exercises all spokes of the integration project for all objects in the model. A test document is sent to each adapter, which converts the generic objects to application specific objects and then converts the application specific objects back to generic objects. The testing tool then documents the return document of each spoke. The result is a catalog of total mappings, partial mappings, and empty mappings. These results may be analyzed to identify disagreements, lost data, and unused fields. The model may then be corrected by updating the mappings.

End-to-end business integration testing tool

Software application integration, including constructing an application integration adapter where the constructing is carried out in dependence upon a profile. The profile includes data describing the adapter. Embodiments include communicating integration messages among applications through the adapter. Profiles include identifications of at least two communications transports, including configuration parameters for the data communications transports. In typical embodiments, constructing an application integration adapter includes creating the transports identified in the adapter profile, and configuring the transports in accordance with the configuration parameters.

Data-driven application integration adapters

Software application integration including providing a multiplicity of predefined data communications receivers, each receiver specific to a software application and a communications protocol; providing a multiplicity of predefined data communications senders, each sender specific to a software application and a communications protocol; providing one or more transports, each transport having the capability of configuring itself, in dependence upon configuration parameters from a profile, with a receiver and a sender; providing a multiplicity of predefined transfer managers; providing an adapter profile identifying communications transports, including receivers and senders, and, optionally, one or more transfer managers, wherein the adapter profile includes configuration parameters for the data communications transports and the transfer managers; and constructing an application integration adapter in dependence upon the profile, wherein the adapter comprises the transports, receivers, senders, and the transfer managers identified in the profile.

Growing community of inventors

Austin, TX, United States of America

Foluso Olaiya Okunseinde