摘要:
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.
摘要:
Provided is an architecture for enabling business components to access middleware components in a runtime environment. A business container hosts business components and services to enable communication between the business components. A plurality of infrastructure components expose interfaces and methods to the business components, wherein the exposed interfaces and methods have names descriptive of a business domain for which the business applications are written. The infrastructure components implementation of the interfaces and methods exposed to the business components include calls to the middleware application programming interfaces (APIs) to invoke middleware APIs to cause middleware operations.
摘要:
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.
摘要:
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.
摘要:
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.
摘要:
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.
摘要:
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.