Patent ID: 7380005

Claim:
In a computer system coupled to an overlay network of broker machines, a method for placing message transformations on the broker machines to improve end-to-end performance, the method consisting of: defining a message transformation flow graph including computational nodes and edges; receiving information about measured and estimated properties of a message flow associated with the message transformation flow graph; receiving information about physical brokers and links in the overlay network onto which the message transformation flow graph is deployed, wherein the information about the physical broker and links are selected from a group consisting of: CPU capacity of each of the physical brokers, link capacity and link latency; labeling each of a plurality of stateless transformations associated with the message transformation flow graph as replicable; heuristically determining a number of replicas and a corresponding load partitioning ratios among the number of replicas for each of the plurality of replicable stateless transformations; converting the message transformation flow graph into an enhanced flow graph having a plurality of virtual replicas of each of the plurality of replicable stateless transformations, and having a plurality of additional data partitioning filter transformations configured to partition a workload for each of the plurality of stateless transformations labeled as replicable; running a placement algorithm with the enhanced flow graph to generate an optimal assignment of the message transformations in the enhanced flow graph to the broker machines in the overlay network; and consolidating each of the plurality of virtual replicas that are assigned to a common message broker.