Request de-duplication for enterprise service bus

• US 8,990,154 B2
• Filed: 01/07/2013
• Issued: 03/24/2015
• Est. Priority Date: 01/07/2013
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Behuria, Ajay K., Bostick, James E., Ganci, John M. Jr., Katare, Shashank, Saha, Shuvamoy, Wenk, David S.
• Primary Examiner(s): NGUYEN, KIM T
• Application Number:
  US13/735,115
• Publication Number:
  US 20140195487A1
• Time in Patent Office: 806 Days
• Field of Search: 707/610, 707/634
• US Class Current: 707/610
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

A method and system for providing temporary storage associated with a duplication request. The method includes authenticating a user accessing a system. A service request for performing service functions is received. Specified data associated with performing service functions is received from a third party vendor and description metadata is added to the specified data. The service functions are executed using the specified data. Results of the executed service functions are generated. An additional service request for performing additional service functions is received and intercepted. The description metadata is compared to previous service requests stored in a temporary storage system.

Claims

1. A method comprising:

authenticating, by a computer processor of a computing system, a user of a system;

accessing, by said computer processor executing an agent in an enterprise service bus (ESB), said system;

receiving, by said computer processor executing said agent, a service request for performing service functions;

selecting, by said computer processor from a service request message dictionary of an integration layer in response to a user command, description metadata configured to form context data uniquely identifying said service request;

receiving from a third party vendor, by said computer processor executing said agent, specified data associated with said performing said service functions;

adding, by said computer processor, said description metadata to said specified data;

executing, by said computer processor via a call to said third party vendor, said service functions using said specified data;

generating, by said computer processor, results of said executing, said results comprising a response to said service request;

receiving, by said computer processor executing said agent, an additional service request for performing additional service functions;

intercepting, by said computer processor, said additional service request;

comparing, by said computer processor executing a mediation component, said description metadata to all previous service requests stored in a temporary storage system, wherein said comparing comprises querying a repository to determine if a duplicate request of said service request has been executed within a past specified time period; and

determining, by said computer processor in response to results of said comparing, if said additional service request comprises said duplicate request or if said additional service request differs from any previous service requests.

2. The method of claim 1, wherein results of said determining determines that said additional service request comprises said duplicate request, and wherein said method further comprises:

retrieving, by said computer processor from said temporary storage system, said specified data.

3. The method of claim 1, wherein results of said determining determines that said additional service request differs from any previous service requests, and wherein said method further comprises:

retrieving, by said computer processor from said third party vendor, additional data;

executing, by said computer processor, additional service functions using said additional data; and

storing in a temporary storage system, by said computer processor, said specified data comprising said description metadata and said results.

4. The method of claim 3, wherein said temporary storage system comprises a cache storage system.

5. The method of claim 4, wherein said cache storage system is comprised by said computer processor.

6. The method of claim 3, further comprising:

determining, by said computer processor, that a specified period of time has elapsed since said storing said specified data comprising said description metadata and said results in said temporary storage system; and

removing, by said computer processor, said specified data from said temporary storage system.

7. The method of claim 1, wherein said request is executed within an integration layer of an enterprise policy administration system.

8. The method of claim 1, further comprising:

providing a process for supporting computer infrastructure, said process comprising providing at least one support service for at least one of creating, integrating, hosting, maintaining, and deploying computer-readable code in the computing system, wherein the code in combination with the computing apparatus is configured to perform the method of claim 1.

9. A computer program product, comprising a computer readable hardware storage device storing a computer readable program code, said computer readable program code comprising an algorithm that when executed by a computer processor of computing system implements a method, said method comprising:

authenticating, by said computer processor, a user of a system;

accessing, by said computer processor executing an agent in an enterprise service bus (ESB), said system;

receiving, by said computer processor executing said agent, a service request for performing service functions;

selecting, by said computer processor from a service request message dictionary of an integration layer in response to a user command, description metadata configured to form context data uniquely identifying said service request;

receiving from a third party vendor, by said computer processor executing said agent, specified data associated with said performing said service functions;

adding, by said computer processor, said description metadata to said specified data;

executing, by said computer processor via a call to said third party vendor, said service functions using said specified data;

generating, by said computer processor, results of said executing, said results comprising a response to said service request;

receiving, by said computer processor executing said agent, an additional service request for performing additional service functions;

intercepting, by said computer processor, said additional service request;

comparing, by said computer processor executing a mediation component, said description metadata to all previous service requests stored in a temporary storage system, wherein said comparing comprises querying a repository to determine if a duplicate request of said service request has been executed within a past specified time period; and

determining, by said computer processor in response to results of said comparing, if said additional service request comprises said duplicate request or if said additional service request differs from any previous service requests.

10. The computer program product of claim 9, wherein results of said determining determines that said additional service request comprises said duplicate request, and wherein said method further comprises:

retrieving, by said computer processor from said temporary storage system, said specified data.

11. The computer program product of claim 9, wherein results of said determining determines that said additional service request differs from any previous service requests, and wherein said method further comprises:

retrieving, by said computer processor from said third party vendor, additional data;

executing, by said computer processor, additional service functions using said additional data; and

storing in a temporary storage system, by said computer processor, said specified data comprising said description metadata and said results.

12. The computer program product of claim 11, wherein said temporary storage system comprises a cache storage system.

13. The computer program product of claim 12, wherein said cache storage system is comprised by said computer processor.

14. The computer program product of claim 11, wherein said method further comprises:

determining, by said computer processor, that a specified period of time has elapsed since said storing said specified data comprising said description metadata and said results in said temporary storage system; and

removing, by said computer processor, said specified data from said temporary storage system.

15. The computer program product of claim 9, wherein said request is executed within an integration layer of an enterprise policy administration system.

16. A computer system comprising a computer processor coupled to a computer-readable memory unit, said memory unit comprising instructions that when executed by the computer processor implements a method comprising:

authenticating, by said computer processor, a user of a system;

accessing, by said computer processor executing an agent in an enterprise service bus (ESB), said system;

receiving, by said computer processor executing said agent, a service request for performing service functions;

selecting, by said computer processor from a service request message dictionary of an integration layer in response to a user command, description metadata configured to form context data uniquely identifying said service request;

receiving from a third party vendor, by said computer processor executing said agent, specified data associated with said performing said service functions;

adding, by said computer processor, said description metadata to said specified data;

executing, by said computer processor via a call to said third party vendor, said service functions using said specified data;

generating, by said computer processor, results of said executing, said results comprising a response to said service request;

receiving, by said computer processor executing said agent, an additional service request for performing additional service functions;

intercepting, by said computer processor, said additional service request;

comparing, by said computer processor executing a mediation component, said description metadata to all previous service requests stored in a temporary storage system, wherein said comparing comprises querying a repository to determine if a duplicate request of said service request has been executed within a past specified time period; and

determining, by said computer processor in response to results of said comparing, if said additional service request comprises said duplicate request or if said additional service request differs from any previous service requests.

17. The computer system of claim 16, wherein results of said determining determines that said additional service request comprises said duplicate request, and wherein said method further comprises:

retrieving, by said computer processor from said temporary storage system, said specified data.

18. The computer system of claim 16, wherein results of said determining determines that said additional service request differs from any previous service requests, and wherein said method further comprises:

retrieving, by said computer processor from said third party vendor, additional data;

executing, by said computer processor, additional service functions using said additional data; and

storing in a temporary storage system, by said computer processor, said specified data comprising said description metadata and said results.

19. The computer system of claim 18, wherein said temporary storage system comprises a cache storage system.

20. The computer system of claim 19, wherein said cache storage system is comprised by said computer processor.