International Business Machines Corporation

John Anthony Reeve

Andrew John Coleman

Trevor Clifford Dolby

Matthew E Golby-Kirk

Doina Liliana Klinger

John Hosie

Chengxuan Xing

Benjamin Graham Thompson

Ashley Donald Harrison

Mark Peter Frost

Paul S M Thorpe

Robert M Convery

Vlad Balanescu

Shanna Xu

Stuart J Reece

Andrew Coleman

Matthew C Bailey

Tom Soal

Alasdair John Paton

Roger A Buckett

Emily Lucy Maryon

Paul Sm Thorpe

A method includes: receiving an initial request message in a request queue of the messaging system; receiving an aggregation reply message in a reply queue of the messaging system, wherein the aggregation reply message is received from an integration system that processes the initial request message, and wherein the aggregation reply message includes an aggregation identifier associated with the initial request message; in response to receiving the aggregation reply message, starting a timeout process; monitoring the timeout process; holding one or more messages that are in the reply queue and that include the aggregation identifier until the timeout process expires or an expected number of responses has been received; and making available the one or more messages that are in the reply queue and that include the aggregation identifier based on the timeout process expiring or the expected number of responses having been received.

Timeout processing for aggregation messaging in an integration environment

A computer-implemented method, system and computer program product for identifying ancestor objects in hierarchical data configured for processing with a query, the query having an associated abstract syntax tree. The abstract syntax tree may be processed so as to generate an augmented abstract syntax tree which includes parent identifiers configured to identify the parent nodes of the query. In this way, a need to pre-parse the data may be alleviated. Instead, the identification of a parent node of a query may be encoded into the abstract syntax tree of the query.

Hierarchical data

A computer-implemented method, system and computer program product for safely processing integrated flows of messages in a multi-tenant container. Each step in the flows of messages to be processed by the applications in the multi-tenant container is monitored. If the monitored step is determined to run custom logic in a general-purpose programming language, then the flow of messages running such custom logic is suspended from being processed by the application in the container if there are other flows of messages being processed by other applications in the container. Furthermore, new flows of messages are prevented from being processed by the applications in the container. After processing the other flows of messages by the other applications in the container, the suspended flow of messages is now processed by the application in the container. In this manner, the risk of interference with other flows of messages in the container is avoided.

Safely processing integrated flows of messages in a multi-tenant container

Generating a target schema is provided. The method comprises receiving an input schema that defines an input structure and receiving a transformation map. The transformation map and the input schema are both parsed, and a first tree for the map and a second tree for the schema are traversed in a step fashion. According to the traversal of the first tree and second tree, a target schema is generated that is valid for all possible instance documents that the transformation map would generate.

Generating target schema based on source schema and query expression

An integration flow can be improved with the use of a pattern identified from a pattern library. The identified pattern can include a snippet of nodes which are functionally equivalent to a subset of nodes in the integration flow. The pattern also lists an endpoint capable of performing the snippet of nodes. The integration flow can therefore be updated to cause the endpoint to perform the snippet of nodes.

Integration flow workload distribution

A method, system, and computer program product for testing a container orchestration system are disclosed. The method includes replicating objects of a production cluster by extracting an object definition from an object and transforming the object definition to create a replicated object definition with an equivalent syntactic form. The replicated object definition requires fewer resources than the object definition. The method also includes applying the replicated objects of the production cluster to a simplified test cluster that replicates a configuration of the production cluster in a scaled down form. Additionally, the method includes testing, with the simplified test cluster, an upgraded version of the container orchestration system.

Generating a test cluster for testing a container orchestration system

An application configuration tool and associated method for supporting deployment of an application on a server that has a set of configurations available for applications deployed on the server. The method attempts to match every configuration required by the application to a configuration available on the server. In case of multiple candidates that match, one is selected. When there is no match an error message is generated. The method is iterated to inspect each selected configuration to identify any references contained in the selected configuration that themselves need further configurations. The iteration of inspecting and the matching to follow the references is continued until all such references are exhausted either by matching or failure to match and consequent error message generation. Finally, a configuration report is output specifying the selected configurations and, to the extent that not all required configurations have been matched to available configurations, the error messages.

Configuration tool for deploying an application on a server

According to embodiments of the present disclosure, a method of debugging datacentric programming languages, a computer program product, and a computer system. The method may comprise receiving, by a processor, an expression to be evaluated against an input data structure; evaluating, by the processor, the expression to produce an output data structure, wherein the evaluating comprises automatically augmenting the input data structure with positional metadata; receiving a user selection of a data element from a datacentric programming element; and in response to the user selection, by the processor, using the positional metadata to display a providence of the selected data element.

Visual declarative debugger

Concepts for creating a mock for an integration flow are presented. One example comprises analyzing a response to each of a plurality of requests from an integration flow and determining whether or not an identifying property of each of the plurality of requests is present in the response. The method then comprises, responsive to determining that the identifying property is present in the response, generating a mock with an associated matcher based on the plurality of requests.

Creating a mock for an integration flow

A computer-implemented method for deploying an application between an on-premise server and an off-premise server includes identifying a plurality of nodes in a flow of an application deployed on the on-premise server. The computer-implemented method further includes splitting the flow at the plurality of nodes to form a plurality of sub-flows of the application. The computer-implemented method further includes routing a flow execution workload of the application to the plurality of sub-flows of the application.

Dynamic integration flows in hybrid cloud environments

A computer-implemented method for a multi-tenant integration environment includes, in response to an error occurring during a state of execution of an integration flow, generating error data for the error. The method further includes associating the generated error data with the error. The method further includes storing the generated error data in a data storage component. The generated error data includes (i) error state information corresponding to the state of execution of the integration flow and (ii) target state information corresponding to a target state of execution of the integration flow.

Multi-tenant integration environment

A computer-implemented method for generating and updating a performance report for a system adapted to run a plurality of flows, which enables the performance data of individual running flows to be compared to flows with a similar function. This is achieved by linking each of the running flows to one of a plurality of templates which describes a function of a flow. Each template may have an associated performance summary generated for it, based on the performance data of the running flows linked to the template. A performance report can be generated from a plurality of the performance summaries. The performance report can then be updated by running a plurality of test flows on the spare capacity of the system, while obtaining test performance data from the test flows. The test performance data can be compared to performance data of running flows on the system linked to the template.

Generating and updating a performance report

A computer-implemented method for automatically redacting logs, comprising receiving a secret associated with a request for service, splitting the secret into a first portion and a second portion, determining whether the second portion has an entropy value greater than a predefined threshold, and in response to the entropy value being greater than the threshold, registering the first portion for protection by a logging service.

Automatically redacting logs

A computer system performs decentralized collection and aggregation of data. A plurality of requests for data are transmitted, by a data collection server, to a corresponding plurality of remote servers, wherein the plurality of remote server submit responses to the plurality of requests for data to a distributed data structure. The distributed data structure is accessed, by the data collection server, to retrieve the plurality of responses to the plurality of requests. The plurality of responses are aggregated, by the data collection server, into a message and the message is transmitted to an entity requesting data collection. Embodiments of the present invention further include a method and program product for performing decentralized collection and aggregation of data in substantially the same manner described above.

Growing community of inventors

Winchester, United Kingdom

John Anthony Reeve