International Business Machines Corporation

Peter R MacFarlane

Simon A J Holdsworth

Andrew Ian Hickson

Michael James Ward

Timothy Nicholas Holloway

Graham R Alderson

Tohru Mori

Adrian W Spender

Execution of a program in a plurality of threads is monitored. Responsive to identifying an exception triggered by the program execution in a first of the plurality of threads, a data collector can be dynamically created for the exception. The data collector can be configured to collect data exclusively relevant to the program execution in the first thread.

Thread based dynamic data collection

Dynamically collecting data pertaining to a program execution. A method can include monitoring execution of the program in a plurality of threads and, responsive to identifying an exception triggered by the program execution in a first of the plurality of threads, initiating at least one data collector to collect data exclusively relevant to the program execution in the first thread.

A method, system, and computer program product for providing asynchronous resumption of a dataflow are provided. The method includes building an executable directed graph from a dataflow that includes multiple interconnected nodes, where at least one of the interconnected nodes is an asynchronous node. The method further includes creating an event flow that includes the asynchronous node and interconnections subsequent to the asynchronous node. The method also includes invoking execution of the executable directed graph, and creating a state object with an identifier associated with the event flow in response to reaching the asynchronous node. The method additionally includes continuing execution of the executable directed graph while avoiding the asynchronous node and the interconnections subsequent to the asynchronous node, and resuming execution of the event flow as identified via the state object upon receiving a response for the asynchronous node.

Methods, systems, and computer program products for asynchronous resumption of a dataflow

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

A method and system for preserving message order when parallel processing messages by: providing a marker (H) in each message (M) for identifying a source of messages for which it is required to preserve the message order; and dispatching (D) each message in accordance with its marker to one of a plurality of parallel processors (P&#x2013;P) so that processing is preserved for messages processed through the plurality of parallel processors. The dispatcher (D) retains a list of all markers of messages that are being processed in parallel, and when a message becomes available to the dispatcher for processing, the dispatcher inspects the list of messages that are currently being processed to determine whether the marker of this message is in the list, and if so delays initiating parallel processing for this message until the marker is no longer in the list. This technique allows a stream of messages originating from multiple sources to be processed with the advantages of parallel processing, while preserving the order of a subset of these messages.

Method and system for preserving message order when parallel processing messages

A data processing network in which a plurality of workstations such as personal computers (PC) (12) are connected to a host processor (11) and contain PC programs at particular levels for controlling tasks on the personal computers. The personal computers send a signal to the host when they are about to conduct a task indicating which data files they have and at what level. The host has an object library containing a copy of each disk file for each version of PC program. The host determines if the personal computer has the latest level data file for the version of program at that personal computer and, if it does not, sends a copy of the latest level data file to the personal computer to replace the down-level data file. Preferably, the host checks if the personal computer has all the data files it needs for the particular task and, if it does not and if it should because of the version of PC program stored at the PC, the host can load a copy of the missing file to the personal computer. The host does not have to contain a record of all the levels of all the programs of all the personal computers connected to it. However, by updating the object library in the host, this arrangement ensures that all personal computers connected to it are automatically brought to the latest authorized level of data files as are required by the personal computer.

Growing community of inventors

Winchester, United Kingdom

Peter R MacFarlane