International Business Machines Corporation

Peter Andrew Broadhurst

Robert William Phippen

Robert Bruce Nicholson

John Hosie

Paul G Clarke

Michael Horan

Gary Thornton

Jitendra K A Patel

Sarah Burwood

Rob Nicholson

Rob Breeds

Jianjun Zhang

A computer-implemented method comprising: receiving, by a computing device, user input defining a workflow; receiving, by the computing device, information defining schemas at convergence points in the workflow; determining, by the computing device, a set of mapping parameters at outputs of nodes of the workflow based on the schemas; receiving, by the computing device, input values to the mapping parameters; storing, by the computing device, the input values to the mapping parameters in a structure corresponding to the schemas; and executing, by the computing device, the workflow based on the input values to the mapping parameters, wherein the executing includes invoking one or more applications residing on one or more application servers through application programming interface (API) calls.

Simplifying data mapping in complex flows by defining schemas at convergence points in a workflow

A method and system for file transfer over a messaging infrastructure are provided. The method includes dividing a file into multiple portions. The method includes generating for a current portion of a file, except for the first portion in a file, a first hash summarizing the state of the file up to, but not including, the current portion and a second hash summarizing the state of the file up to and including the current portion. The method includes sending the first and second hashes with the file portion. The second hash may be used at a target for comparing to a first hash of a subsequent file portion, for example, by recreating the second hash from the current state of the received file on the target.

Method and system for file transfer over a messaging infrastructure

A facility for processing an event of a distributed processing environment is provided. The facility includes separating a plurality of processing flows into a plurality of flow groups, each flow group having a respective identifier. The identifier of each flow group is then associated with a respective topic. Based on the occurrence of an event, a message having a topic based on the event is published along with the identifier of the flow group associated with the topic. A processing flow of the flow group having the identifier of the message may then be used to process the event.

Event processing

A method and associated system. For each message of a message batch, the message is assigned by a consumer to a partition of a log. Each partition of the log is associated with a respective processing engine. The message batch includes messages that includes the message. The consumer stores an offset value for each partition. Responsive to completion, by a distributor, of sending a last message in the message batch to the consumer, the distributor ascertains a target offset value for each partition based on a current offset value. In response to a processing engine completing processing of a message assigned to the partition associated with the processing engine, the consumer updates the stored offset value associated with the partition. The distributor determines when all messages of the batch have been processed based on the target offset values and the stored offset values.

Batch processing of messages

A method, system and article of manufacture are disclosed for selecting a channel instance for connecting a client application with a server application in a multi-channel computer system. In this computer system, when a new channel instance is used to connect one of the client applications with one of the server applications, defined channel instance information is established for the channel instance. The method of this invention comprises the steps of when a new application connection request is made, locking existing channel instance information; and after said locking, scanning through a list of channel instance connections for one of the channel instances that is a candidate channel instance for that new application connection request. The method comprises the further steps of, in response to finding a candidate channel instance, determining whether the candidate channel instance is suitable for the new application connection request.

Efficient selection of a messaging multiplexed channel instance

A method, system and article of manufacture are disclosed for selecting a channel instance for connecting a client with a server in a multi-channel instance computer system. In this computer system, when a new channel instance is used for connecting the client with one of the servers, defined channel information is established for the channel instance. The method of this invention comprises the steps of, when a new connection request is made, locking existing channel information; and after said locking, scanning through a list of channel connections for one of the channel instances that is a candidate for said connection request. In response to finding a candidate channel instance, which is in the process of connecting, the connection request is queued against the candidate channel instance. When the candidate channel instance does not complete connecting within a defined or determined time period, a new channel instance is used for the connection request.

Growing community of inventors

Eastleigh, United Kingdom

Peter Andrew Broadhurst