Patent ID: 7814470

Claim:
A method executed in a facility, the method comprising: providing a data integration platform, in a service oriented architecture, comprising a code module for executing a data integration job, wherein the code module is stored in a registry of services; defining a real-time integration service that exposes the data integration platform as a set of abstract services, wherein each abstract service is agnostic to a particular type of service binding and is accessible by more than one type of service binding; and responsive to receiving a request, invoking the real-time integration service to perform the data integration job using the code module, wherein the real-time integration service is invoked in real time by more than one type of service binding such that different applications can utilize the real-time integration service using different protocols to invoke the real-time integration service, wherein the request is marked by a start-of-wave marker and an end-of-wave marker, and wherein the request is invoked as the request is received, wherein invoking the real-time integration service to perform the data integration job using the code module further comprises: receiving the request for real time integration of data into a pipeline containing individual requests, by a real time integration agent of a computing facility, wherein each request in the pipeline is marked with the start-of-wave marker and the end-of-wave marker enabling the real time integration agent to recognize an initiation of the request and a completion of a data integration job instance associated with the request; and responsive to existence of the start-of-wave marker, processing the request for real time integration of data by the real time integration agent of the computing facility from the plurality of data sources, accessible to the computing facility, wherein the request corresponds to a transaction in the pipeline, and wherein multiple transactions are in the pipeline simultaneously.