International Business Machines Corporation

John Michael Knapman

Andrew Ian Hickson

David Ware

Brian Clive Homewood

Steven William Bolam

Robert William Phippen

Colin Leonard Bird

Sydney George Chapman

John Bryan Ibbotson

Michael Wayne Young

Ian Henderson

James York

A message transformation selection tool and method for use in a distributed message processing system running applications on subsystems using incompatible message formats, selects the most appropriate output message format for a given input message format. Firstly, the tool determines compatibility of each field of the input message format with fields of all possible output message formats. Next, it statistically analyses the values of message fields in messages stored in message logs for each of the subsystems. On the basis of this analysis, the tool selects the best fit output message into which to transform a given input message.

Message transformation selection tool

A message transformation selection tool and method for use in a distributed message processing system running applications on subsystems using incompatible message formats, selects the most appropriate output message format for a given input message format. Firstly, the tool determines compatibility of each field of the input message format with fields of all possible output message formats. Next, it statistically analyzes the values of message fields in messages stored in message logs for each of the subsystems. On the basis of this analysis, the tool selects the best fit output message into which to transform a given input message.

Message transformation selection tool and method

In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data from a subscriber application, a first broker data processing apparatus has: a unit for receiving a data message published on a first topic by a first publisher application; and a unit for forwarding the received published data message to a subscriber application which has requested, by entering subscription data, to receive a message on the first topic; wherein the first broker data processing apparatus sends a declaration to at least one other broker data processing apparatus of said plurality of broker data processing apparatuses declaring that the first broker data processing apparatus is the only broker data processing apparatus that is directly communicating with a publisher application that is publishing on the first topic.

Publish and subscribe data processing apparatus, method and computer program product with declaration of a unique publisher broker

In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses, each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data directly from a subscriber application, and each of which having a means for receiving a published message on a first topic and assigning a broker-specific sequence number to the received message; a first broker apparatus has: a software unit for determining a failure of a neighboring broker apparatus which has provided published messages on the first topic to the first broker apparatus; and a software unit for sending historic resubscriptions with respect to the first topic to each antecedent broker apparatus of the failed neighboring broker apparatus by using the broker-specific sequence number corresponding to each antecedent broker apparatus.

Publish and subscribe data processing with failover using cascaded sequence numbers

A publishing data processing method for use in a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data directly from a subscriber application, the method includes steps of: Publishing a message on a topic to a first broker data processing apparatus; and providing an indication as to whether the published data message is to be considered as local to the first broker apparatus. Also included are an analogous subscribing data processing method, an analogous broker data processing method, apparatuses and computer program products.

Publish and subscribe data processing with ability to specify a local publication/subscription

In a publish/subscribe data processing broker network having a plurality of broker data processing apparatuses each of which has an input for receiving published messages directly from a publisher application and/or receiving subscription data from a subscriber application, a first broker apparatus has: a software unit for receiving via said input subscription data from a subscriber application; a software unit for providing an acknowledgement to said subscriber application to acknowledge that the subscription data has been received; a software unit for propagating said subscription data to a group of other broker apparatuses; a software unit for determining whether said means for propagating has propagated said subscription data to the group of other broker apparatuses; and a software unit for receiving via said input an indication from said subscriber application that said acknowledgement should not be sent to the subscriber application until the means for determining has determined that said means for propagating has propagated said subscription data to the group of other broker apparatuses.

Publish and subscribe data processing with subscriber option to request

Provided are transaction processing systems and methods enabling interoperation between data processing resources which implement different transaction processing models. The systems and methods also enable resources which were not created using object oriented programming techniques to interoperate with object oriented programs and to utilise object orientation concepts. The systems and methods allow transactions to be controlled using consistent operations across multiple object oriented transaction services. A set of object classes is implemented on a transaction processing system, the object classes including: an object oriented wrapper (300) for an existing system interface; an interface implementation (310) which corresponds to a different transactional model from that of other system resources; and a transaction class (320) which maps transactional operations of one model to transactional operations of the second model, while taking account of transactional operations which are within transactional scope according to one model and outside transactional scope according to the second model.

Data processing systems and methods providing interoperability between

An apparatus for detecting errors in frames of seismic data that can be presented as images, such images being expected to exhibit an inherent symmetry about an axis, the apparatus comprising: a storage device for storing a frame of seismic data which can be presented as an image; a selection device for selecting an axis within the image as the axis of symmetry; a divider for dividing the data about the axis of symmetry to create first and second sets of data; and a comparison means for comparing the sets of data according to preselected matching criteria to determine, based on the degree of matching, whether the extent of mismatch in the frame of data is within a predetermined tolerance.

Growing community of inventors

Eastleigh, United Kingdom

John Michael Knapman