Dynamic service-on-demand delivery messaging hub

• US 7,849,130 B2
• Filed: 04/30/2003
• Issued: 12/07/2010
• Est. Priority Date: 04/30/2003
• Status: Expired due to Fees

• Current Assignee: LinkedIn Corporation (Microsoft Corporation)
• Original Assignee: International Business Machines Corporation
• Inventors: Madduri, Hari Haranath, Chang, Philip Yen-tang, Albaugh, Virgil A., Benantar, Messaoud
• Primary Examiner(s): Burgess; Barbara N.
• Application Number:
  US10/427,097
• Publication Number:
  US 20040221005A1
• Time in Patent Office: 2,778 Days
• Field of Search: 709/203, 709/226
• US Class Current: 709/203
• CPC Class Codes: H04L 67/01 Protocols
• CPC Class Codes: H04L 67/51 Discovery or management thereof, e.g. service location protocol [SLP] or web services
• CPC Class Codes: H04L 69/329 in the application layer [OSI layer 7]

Abstract

An infrastructure for on-demand service delivery receiving a request for a service to be performed from a service consumer with an information payload; decomposing requested service into essential or primitive functions; dynamically composing a sequence of a plurality of service elements corresponding to the essential or primitive functions to accomplish the service by employing a function call and return decomposition and recomposition paradigm; creating a control header and information payload, the control header encapsulating the sequence; repeatedly dispatching the control header to each service element in the sequence until all service elements have processed the information payload; and returning the processed information payload to the service consumer.

Claims

1. A method performed by a computing platform comprising:

receiving by a computing platform a request for a service to be performed from a service consumer, the request having an information payload upon which the requested service is to be performed;

responsive to receipt of the request;

decomposing by a computing platform the requested service into a plurality of essential or primitive functions;

dynamically composing by a computing platform a sequence of a plurality of service elements corresponding to the plurality of essential or primitive functions to be employed to accomplish the service, wherein the composing employs a function call and return decomposition and recomposition paradigm;

creating by a computing platform a control header and information payload, the control header encapsulating the sequence of the plurality of service elements;

repeatedly dispatching by a computing platform the control header to each service element in the composed sequence until all service elements have processed the information payload; and

responsive to the dispatching so all service elements, returning the processed information payload to the service consumer.

2. The method as set forth in claim 1 wherein the control header comprises an Extensible Markup Language data structure.

3. The method as set forth in claim 1 wherein the step of receiving a request comprises receiving a request via a canonical messaging interface.

4. The method as set forth in claim 1 wherein the step of dispatching the control header comprises dispatching via a canonical messaging interface.

5. The method as set forth in claim 1 further comprising:

maintaining a registry of service elements and the functions; and

upon receipt of a deregistration request from a registered service element, removing the registered service element from the registry such that the service element will not be used in subsequently composed services.

6. The method as set forth in claim 1 further comprising providing a hub having a messaging broker, a dynamic service composer, a service element registry, a delivery element, a dispatcher element, and a registration element.

7. The method as set forth in claim 6 wherein the dispatcher element and the delivery element are provided with a canonical messaging interface.

8. A computer readable memory medium for providing services from a service provider to a service consumer comprising:

at least one computer readable memory suitable for encoding program instructions for a processor; and

a plurality of program instructions encoded by the computer readable memory;

a first program instruction receiving a request for a service to be performed from a service consumer, the request having an information payload upon which the requested service is to be performed;

a second program instruction, responsive to receipt of the request;

decomposing by a computing platform the requested service into a plurality of essential or primitive functions;

dynamically composing a sequence of a plurality of service elements corresponding to the plurality of essential or primitive functions to be employed to accomplish the requested service, wherein the composing employs a function call and return decomposition and recomposition paradigm;

a third program instruction creating a control header and information payload, the control header encapsulating the sequence of the plurality of the service elements;

a fourth program instruction repeatedly dispatching the control header to each service element in the composed sequence until all service elements have processed the information payload; and

a fifth program instruction responsive to the dispatching so all service elements, returning the processed information payload to the service consumer.

9. The computer readable memory as set forth in claim 8 wherein the creating a control header comprises creating an Extensible Markup Language data structure.

10. The computer readable memory as set forth in claim 8 wherein the receiving a request comprises receiving a request via a canonical messaging interface.

11. The computer readable memory as set forth in claim 8 wherein the dispatching a control header comprises dispatching via a canonical messaging interface.

12. The computer readable memory as set forth in claim 8 further comprising:

a sixth program instruction maintaining a registry of service elements and the functions; and

a seventh program instruction, upon receipt of a deregistration request from a registered service element, removing the registered service element from the registry such that the service element will not be used in subsequently composed services.

13. The computer readable memory as set forth in claim 8 further comprising an eighth program instruction having a messaging broker, a dynamic service composer, a service element registry, a delivery element, a dispatcher element, and a registration element.

14. The computer readable memory as set forth in claim 13 wherein the dispatcher element and the delivery element comprise program instructions for a canonical messaging interface.

15. A system for providing on-demand, dynamically composed services to a service consumer from a service provider, the system comprising:

a computing platform having a processor configured to perform a logical process;

at least one client service request received from a service consumer by the computing platform, the service request having an information payload upon which the requested service is to be performed;

a hub subsystem of the computing platform, responsive to the received service request;

decomposing by a computing platform the requested service into a plurality of essential or primitive functions;

dynamically composing by a computing platform a sequence of a plurality of service elements corresponding to the plurality of essential or primitive functions to be employed to accomplish the service, wherein the composing employs a function call and return decomposition and recomposition paradigm;

creating by a computing platform a control header and information payload, the control header encapsulating the sequence of the plurality of the service elements; and

repeatedly dispatching by a computing platform the control header to each service element in the composed sequence until all service elements have processed the information payload; and

a processed payload returned to the service consumer from the hub subsystem responsive to completion of dispatching the control header to each of the service elements in the composed sequence.

16. The system as set forth in claim 15 wherein the control header comprises an Extensible Markup Language data structure.

17. The system as set forth in claim 16 wherein the hub subsystem comprises a canonical messaging interface for receiving the service request.

18. The system as set forth in claim 16 wherein the hub subsystem comprises a canonical messaging interface for dispatching the control header.

19. The system as set forth in claim 15 further comprising:

a registry of service elements and the functions portion of the hub subsystem; and

a registry updater portion of the hub subsystem removing a registered service element from the registry responsive to receipt of a deregistration request.

20. The system as set forth in claim 15 wherein the hub subsystem comprises a messaging broker, a dynamic service composer, a service element registry, a delivery element, a dispatcher element, and a registration element.

21. The system as set forth in claim 20 wherein the dispatcher element and the delivery element are provided with a canonical messaging interface.

22. The system as set forth in claim 15 wherein the plurality of service elements are provided with a canonical messaging interface.

23. The system as set forth in claim 15 wherein the hub and service elements are provided with compatible canonical messaging interfaces.

24. A method performed by a computing platform comprising:

receiving by a computing platform a request for a service to be performed from a service consumer, the request having an information payload upon which the requested service is to be performed;

responsive to receipt of the request;

decomposing by a computing platform the requested service into a plurality of essential or primitive functions;

dynamically composing by a computing platform a sequence of a plurality of service elements corresponding to the plurality of essential or primitive functions to be employed to accomplish the service;

creating by a computing platform a control header and information payload, the control header encapsulating the sequence of the plurality of service elements;

repeatedly dispatching by a computing platform the control header to each service element in the composed sequence until all service elements have processed the information payload;

responsive to the dispatching so all service elements, returning the processed information payload to the service consumer;

maintaining a registry of service elements and the functions; and

upon receipt of a registration from a new service element, adding the service element to the registry for subsequent use in performing dynamically composed services.