International Business Machines Corporation

General Electric Company

Marc-Thomas Schmidt

Timothy Nicholas Holloway

Stephen James Todd

Michael Starkey

Stephen James Paul Todd

Yael Shaham-Gafni

Gabi Zodik

Michael George Taylor

Malcolm David Ayres

Vipul Parmar

Suparna Pal

Neta Aizenbud-Reshef

Charles Daniel Wolfson

Constance Jane Nelin

Simon Antony James Holdsworth

Michael Hart

Simon Anthony James Holdsworth

Subrata Roy

Harel Kodesh

Himagiri Mukkamala

Steve Winkler

Systems and methods for deploying runtime environment-agnostic services are presented. In an example embodiment, an indication is received of a runtime environment in which a first programming code and a second programming code are to execute. The second programming code includes a dependency to the first programming code that is abstracted from the runtime environment. An artifact of the first programming code and an artifact of the second programming code are accessed from a data store based on the indication of the runtime environment. The artifact of the first programming code and the artifact of the second programming code are integrated to yield integrated programming code. The integrated programming code is deployed to the indicated runtime environment.

Deployment of environment-agnostic services

Systems and methods described herein are configured for managing industrial assets. In an example embodiment, information about industrial assets or their use conditions, such as gathered from sensors embedded at or near industrial machines or assets themselves, can be aggregated, analyzed, and processed in software residing locally or remotely from the assets. In an example embodiment, applications can be provided to optimize an industrial asset for operation in a business context. In an example embodiment, a cloud-based asset management platform can include development tools to facilitate development, by end-users, of applications for interfacing with and optimizing industrial assets, and for managing relationships between various industrial assets.

Systems and methods for managing industrial assets

A message broker data processing apparatus comprising: a unit for receiving published messages on a topic from a plurality of publisher applications; a unit for processing the received messages; and a unit for distributing the processed messages to a subscriber application; wherein the unit for receiving includes a plurality of publication point data processing nodes, each of which receives published messages on the topic from a publisher application.

Publish/subscribe data processing with publication points for customized message processing

Provided are an execution monitoring tool, a method and a computer program product for monitoring a message processing program or system. The execution monitoring tool identifies locations within the message processing program corresponding to a predefined set of execution progress stages, and inserts execution progress report generator components at these locations. Execution progress reports (including a representation of the message contents and structure) are then sent to the execution monitoring controller which maps the report data to its own representation of the program to determine the current position within an execution program. The message contents and structure, as well as the structure of the program and the current execution position, are displayed during execution on a test system. The execution reports include the current execution status as well as the position within the execution flow.

Monitoring messages during execution of a message flow

Provided are an execution monitoring tool, a method and a computer program product for monitoring execution of an hierarchical visual program. Execution progress reports are sent to an execution monitoring controller which maps the report data to its own representation of the hierarchical program to determine the current position within an execution program. The hierarchical structure of the program and the current execution position are displayed during execution on a test system. The execution monitoring controller maintains an hierarchical representation of the visual program's structure, builds an execution stack from the execution progress reports, and compares the received reports with the hierarchical representation to determine a current execution position. The execution reports include the current execution status as well as the position within the execution flow. In an implementation of the invention for debugging a visual message flow, which represents a sequence of message processing operations as a set of nodes and connections between the nodes, the execution progress reports include the content and structure of the message during execution and this is also displayed to the user. A set of debug nodes for generating the execution progress reports are preferably automatically inserted in the message flow before executing it on a test and debugging system, and these debug nodes send execution progress reports to a debug controller.

Monitoring execution of an hierarchical visual program such as for debugging a message flow

A message broker data processing apparatus has a unit for receiving published messages on a topic from a publisher application; a unit for processing the received messages; and a unit for distributing the processed messages to subscriber applications; wherein the unit for distributing includes a plurality of subscription point data processing nodes, a first subscription point data processing node distributes messages to a subscriber application which has previously registered a subscription request identifying the first subscription point data processing node with the broker apparatus.

Publish/subscribe data processing with subscription points for customized message processing

Provided is a method, system, and program for processing a data flow. A message is received at an input node. The message is transferred to a plurality of nodes according to a defined data flow. At one stored procedure node, the message is processed to generate input parameters for a stored procedure call. The stored procedure node transfers the stored procedure call to a stored procedure at a server computer, wherein the server executes the stored procedure to process data and generate output.

Method, system, and program for accessing stored procedures in a message broker

Growing community of inventors

Winchester, United Kingdom

Marc-Thomas Schmidt