International Business Machines Corporation

Andrew Ian Hickson

David Ware

Brian Clive Homewood

Gary Patrick Longerstaey

John Michael Knapman

Steven William Bolam

Nigel Goddard

Michael James Ward

Stuart J Reece

Philip Graham Willoughby

George M Blue

Peter R MacFarlane

Simon A J Holdsworth

James Gordon Wilkinson

Timothy Nicholas Holloway

Malcolm David Ayres

Andrew M Leonard

Richard Scott Maxwell

Paul Cullen

Martin James Gompertz

Andrew J Whitfield

Andrew James Stanford-Clark

David Locke

Peter David Niblett

Ian Gerald Craggs

Trevor Lobban

Andrew David Reynolds

Richard M W Harran

Tristram Terence Reilly

Robert F Buxton

Anthony Alan Garrard

Andrew Anthony Emmett

Martin R Holder

Andrew David Akehurst

David John McCann

Mark P Dyche

Andrew Stephen Marcus Edwards

Ian W Parkson

Ian Robert Harwood

Jane Louise Stockdill

Timothy Steven Raff

George Meldrum Blue

Philip Graham Wiloughby

A method of managing an asynchronous messaging queue with a client computer in an asynchronous messaging system, where the client computer is programmed to store an manage the asynchronous messaging queue, includes receiving a reactive message in the asynchronous messaging queue, the reactive message including an identification of a previously initiated message and an action to be performed on the previously initiated message; and upon determining that the previously initiated message has already been received in the asynchronous messaging queue, performing the action on the previously initiated message with the client computer.

Managing queues in an asynchronous messaging system

Disclosed is a method for administering messages. In response to a determination that one or more consuming applications have failed to process the same message on a queue a predetermined number of times, the message is made unavailable to consuming applications. Responsive to determining that a predetermined number of messages have been made unavailable to consuming applications, one or more consuming applications are prevented from consuming messages from the queue.

Method, apparatus and computer program for administering messages which a consuming application fails to process

A method is provided for using a temporary object handle. The method performed at a resource manager includes: receiving an open temporary handle request from an application for a resource object, wherein a temporary handle can by asynchronously invalidated by the resource manager at any time; and creating a handle control block at the resource manager for the object, including an indication that the handle is a temporary handle. The method then includes: responsive to receiving a request from an application to use a handle, which has been invalidated by the resource manager, sending a response to the application that the handle is invalidated.

Using a temporary object handle to control access to a resource object

A system is provided for using a temporary object handle. The system includes a resource manager: receiving an open temporary handle request from an application for a resource object, where a temporary handle can by asynchronously invalidated by the resource manager at any time; and creating a handle control block at the resource manager for the object, including an indication that the handle is a temporary handle. The system then includes the resource manager: responsive to receiving a request from an application to use a handle, which has been invalidated by the resource manager, sending a response to the application that the handle is invalidated.

Opening a temporary object handle on a resource object

Documents are published in a publish subscribe data processing system. A first document to be published may have an associated topic. The first document is retained as a retained document. A second document to be published is retained as the retained document in response to receiving the second document before a predetermined time interval has passed. A copy of the second document is sent to a subscriber of the topic. A copy of the retained document is sent to the subscriber of the topic in response to a determination that the predetermined time interval has passed.

Publishing documents in a publish/subscribe data processing system

A system and method for messaging in which, when a connection to a queue manager () is established, the queue manager allocates a Connection Identifier from the same name space () as Message Identifiers and returns this information () to the user. The user can then use this Connection Identifier as a Correlation Identifier, safe in the knowledge that it will not clash with any system generated Message Identifier or Correlation Identifier. A secondary benefit to this allocation scheme is that if a shared reply queue suffers from a build-up of messages then the Correlation Identifier in those messages can be used to identify the application expected to receive those messages.

System and method for messaging

A method and system for combined commit transaction request and subsequent operation request for committing the operations of a synchronized transaction by one or more applications () on a resource manager (). The method comprises: receiving a combined request () for an operation and a request to commit any outstanding synchronized transaction; committing the outstanding transaction (); and processing () the requested operation outside the outstanding transaction. For example, in an asynchronous messaging process, the combined request specifies an option in a get operation request to commit any outstanding units of work prior to carrying out the get operation.

Method and system of committing operations of a synchronized transaction

Provided are a message brokering systems, computer program products and methods for communication in a publish/subscribe environment in which publisher application programs send messages to subscriber application programs via one or more message brokers, the method comprising the following steps: responsive to receipt of a published message at a message broker, referring to characteristics of the received message and subscriber-specified quality of service requirements to determine an appropriate quality or service for onward transmission of the message; selecting a communication protocol in accordance with the determined quality of service; and transmitting the message using the selected communication protocol. Information relating to the quality of service requirements of a first message broker's subscribers is passed to other brokers and subsequently used for selection of an appropriate communication protocol for transmitting messages between the brokers.

Selection of communication protocol for message transfer based on quality of service requirements

Managing an asynchronous messaging queue with a client computer in an asynchronous messaging system, where the client computer is programmed to store an manage the asynchronous messaging queue, includes receiving a reactive message in the asynchronous messaging queue, the reactive message including an identification of a referenced message and an action to be performed on the referenced message; and performing the action on the previously initiated message with the client computer if the referenced message is present in the asynchronous messaging queue.

An apparatus browses a list of data items. The apparatus includes a plurality of browse mechanisms each operable to scan concurrently through a list of data items and a plurality of independent groups each comprising two or more of the plurality of browse mechanisms. The browse mechanisms in a group cooperate together to browse the list of data items such that a data item is seen by only one member of the group.

Browsing a list of data items

The present invention provides methods, apparatus and computer programs for event-based control of subscription matching in a publish/subscribe communications environment. Activation and/or deactivation events are associated with subscriptions at a publish/subscribe broker and are used to control when a subscription is active. The broker is responsive to temporally-unpredictable events, such as receipt of a published message on a predefined activation topic, to activate subscription matching for messages that are subsequently received or which have been received earlier and retained at the broker. Conventional subscription matching can be avoided for a registered subscription while that subscription is inactive, and subscribers are not required to explicitly and repeatedly subscribe and unsubscribe.

Event-based activation and deactivation of subscription matching

Generating exception delay messages when messages communicated between asynchronous messaging applications are delayed and for forcibly retaining the original message. Specifically, the invention provides methods and systems for generating an exception delay message after a time threshold has expired without deleting the original message. The exception delay message may be sent once when the time threshold first expires or each time that the time threshold expires.

System and method for generating exception delay messages when messages are delayed

A method and system of inherited transactions in an asynchronous messaging are provided. A producer requests a message put operation in a transaction. A consumer carries out a get operation with the option to inherit the transaction of the put operation. In an inherited transaction, the consumer's transaction will not commit until the transaction it has inherited from commits. Work performed in the producer's transaction is visible to the consumer, but work performed in the consumer's transaction is not visible to the producer preserving asynchronous messaging semantics. A transaction hierarchy results and only the net effect of transaction hierarchy is hardened to non-volatile storage.

Inherited transactions in asynchronous messaging

Growing community of inventors

West Wellow, United Kingdom

Andrew Ian Hickson