International Business Machines Corporation

John Christopher Hawkins

David John Vines

Matthew Robert Whitehead

Hao Yang

Francis Nicholas Parr

John Bryan Ibbotson

Mark Patrick Nuttall

A method for distributing cached messages in a load-balanced publish/subscribe messaging network using an HTTP redirect in response to an HTTP client message request is disclosed. The redirect response including a URI at which a next message in a list of sequential messages slated for the HTTP client per the request is located, wherein the HTTP client uses the URI to automatically iterate through and receive the entire list of sequential messages. The method includes that a) the HTTP client initiating a request for a next message in a sequence of messages, b) the HTTP server receiving the request and creating and inserting a client cursor in a message cache for the HTTP a cache location of the requested next message, and returning an HTTP redirect response to the HTTP client including the current client cursor cache location for the requested next message in a location field in the redirect response enabling the HTTP client to automatically access each next message in the sequence and c) the HTTP client receiving the redirect response, opens (sends) a new request to the client cursor location in accordance with the URI location field in the redirect response to secure the next message, Steps b) and c) are repeated until the HTTP server returns a response other than a redirect response, or until the HTTP client fails to respond to a redirect response. The method, system and computer program product supports point-to-point messaging.

Cached message distribution via HTTP redirects

Message brokering in a consuming broker device of a publish-subscribe system having at least one processor includes: designating in the consuming broker device a first producing broker device as a sole provider of messages having a topic to which the consuming broker device has subscribed; and in response to a determination that a measured livelihood of the first producing broker device is less than a defined threshold, designating with the consuming broker device a second producing broker device as the sole provider of the messages having the topic to the consuming broker device. The second producing broker device has a measured livelihood that is greater than the measured livelihood of the first producing broker device.

Message brokering in a consuming broker device

Transforming an original message from an application executed by a physical computing device to create a message readable by a plurality of heterogeneous recipients includes: creating with the physical computing device a first sub-message having data from the original message that is readable by each of the heterogeneous recipients; creating with the physical computing device a second sub-message having data from the original message that is not readable by each of the heterogeneous recipients; and generating with the physical computing device a composite message including both the first sub-message and the second sub-message.

Creating a message readable by a plurality of heterogeneous recipients

Message type validation occurs at a message producer before a message is sent to a message destination. A message producer system includes an administrator component, which stores message type parameters associated with a message destination. A message is created for the message destination and a validation component at the message producer system checks the created message for conformity with the stored message type parameters for the message destination. An error is reported if the message type does not conform to the stored message type parameters associated with the message destination. The validation component checks the created message for conformity after a publish call by the message producer system and before a send call and, therefore, prevents an invalid or non-conforming message from being sent.

Message producer with message type validation

The present invention is generally directed to a method, system, and article of manufacture that avoid exposing the sensitive information (e.g., infrastructure details) to untrusted clients. For example, in one embodiment of the present invention, message destinations are protected from a client in an HTTP bridged scenario. Thus, according to one embodiment of the present invention, the replyTo message destination are obfuscated (e.g., via a hash function) and sent to the client as a replyTo address. Consequently, the embodiments of the present invention negate the requirement to expose the sensitive information to the untrusted client applications.

System and method of obfuscating queue management

A method and system for message delivery in a messaging network are provided for enabling scaling. A messaging network includes a group of a plurality of queue managers, each of which includes means for carrying out a method comprising: receiving a message at a queue manager, removing at least some of the original message data to form a link message, adding a reference to the link message referring to the queue manager, sending the link message to a link message queue, and putting the original message to a local queue on the first queue manager. A link message queue may provided on each of the queue managers in the group, or single link message queue may be provided on one queue manager and accessible by the other queue managers in the group.

Message delivery using a plurality of queue managers

The invention includes a publish/subscribe system for publish/subscribe messaging utilizing pre-emptive subscriptions in a cluster of HTTP servers that includes load balancing. The system includes at least one HTTP client in a role of HTTP subscriber, and a set HTTP servers arranged as an HTTP server cluster in communication with each other and the at least one HTTP client in a network infrastructure, where each HTTP server is subscribed to a special topic: admin/subscriptions, maintains a subscription to requested topics for a client and a message history of messages published on that topic. Each server can serve messages to different HTTP clients at different times based on the HTTP client's 'cursor' in the HTTP server's message history list, and wherein any HTTP client request for a 'next' message on a given requested topic will follow their cursor progress through the message history list.

System and method for non-HTTP session based publish/subscribe support using pre-emptive subscriptions

A tool operable within an integrated development environment for client-server object oriented applications is disclosed. The tool analyzes a running application to trace the first instantiation of classes within the application; groups classes according to when they are first instantiated into respective groups; and means archives these groups into respective archive files capable of being decoded prior to execution of the application on a client.

Growing community of inventors

Southampton, United Kingdom

John Christopher Hawkins