Extendable event processing through services

• US 8,661,456 B2
• Filed: 10/31/2011
• Issued: 02/25/2014
• Est. Priority Date: 06/01/2011
• Status: Active Grant

• Current Assignee: Hewlett Packard Enterprise Development LP (Hewlett-Packard Enterprise Company)
• Original Assignee: Hewlett-Packard Development Company, L.P. (HP Inc.)
• Inventors: Wang, Yanlin, Sharan, Dhiraj
• Primary Examiner(s): Troung, Lechi
• Application Number:
  US13/285,939
• Publication Number:
  US 20120311611A1
• Time in Patent Office: 848 Days
• Field of Search: 719/318
• US Class Current: 719/318
• CPC Class Codes: G06F 9/541 via adapters, e.g. between incompatible applications
• CPC Class Codes: G06F 9/547 Remote procedure calls [RPC]; Web services

Abstract

A system for extending event processing through services includes an event process module to process event data according to event processing rules and services. A build-time system provides an interface for adding or modifying services. A service request gateway receives service requests from service consumers and receives event data from event data providers and provides the service requests to a service container module and provides the event data to the event process module. The service container modules invokes services for the service requests.

Claims

1. A system for extending event processing through services, the system comprising:

at least one processor;

an event process module, executed by the at least one processor, to process event data according to event processing rules and by services provided by service applications;

a build-time system, executed by the at least one processor, to provide an interface for adding or modifying the services provided by the service applications;

a service request gateway, executed by the at least one processor, to receive service requests from service consumers and to receive the event data from event data providers and to provide the service requests to a service container module and to provide the event data to the event process module, and

the service container module, executed by the at least one processor, to invoke the services responsive to receiving the service requests from the service request gateway, wherein the service container module is to determine if a service request of the service requests is an asynchronous service request or a synchronous request, and

if the service request is an asynchronous service request, send an acknowledgment to a service consumer of the service consumers sending the service request, wherein the acknowledgement comprises a reference ID for making a status request about service execution, and if the service request is a synchronous service request, process the service request without sending the acknowledgment to the service consumer.

2. The system of claim 1, comprising a service code generator to receive the service applications and to generate exposed service applications that are each exposed to a plurality of different service bindings.

3. The system of claim 2, wherein the exposed service applications include adaptors to provide a service using any of the plurality of different service bindings.

4. The system of claim 2, wherein the service applications comprise plain old java object service applications and are annotated with service annotations, wherein the service annotations include an indication of the service bindings to use for each of the service applications.

5. The system of claim 1, wherein the service request gateway comprises a single port to receive the service requests and the event data.

6. The system of claim 1, wherein the service request gateway is to receive a Hypertext Transfer Protocol request, and determine if information in the request is one of the service requests or the event data based on header information in the request.

7. The system of claim 6, wherein the service request gateway is to send context for a service consumer to the service container module if the request is determined to be a service request, wherein the context is used to keep track of which service consumer is making the service request.

8. The system of claim 1, wherein for each service request the service container module is to call a service identified from the service request to execute the service.

9. The system of claim 1, wherein a service for one of the service requests is executed by the event process module.

10. The system of claim 1, comprising:

a plurality of modules in a module core framework to provide lifecycle management of services, dependency management of services, container management for services, logging activities in the system and user authentication.

11. The system of claim 1, wherein the service container module exposes event processing workflow control services and event control correlation services as services consumable by the service consumers.

12. The system of claim 1, wherein the service container module exposes a service consumable by the service consumers, wherein the service provides statistics for the event data, wherein external systems of the service consumers are to perform actions based on the statistics.

13. A method comprising:

receiving information at a service request gateway;

determining whether the information is event data or a service request;

if the information is event data, sending the event data to an event process module in a platform to process the event data according to event processing rules;

if the information is a service request,

sending the service request to a service container module in the platform, and determining context data and a service to call for the service request;

determining, by the service container module, if the service request is an asynchronous service request or a synchronous request;

if the service request is an asynchronous service request, sending an acknowledgment to a service consumer sending the service request, wherein the acknowledgement comprises a reference ID for making a status request about service execution; and

if the service request is a synchronous service request, processing the service request without sending the acknowledgment to the service consumer;

executing the service, by a processor, in the platform; and

sending results of executing the service from the service container module to a service container via the service request gateway.

14. The method of claim 13, wherein executing the service comprises:

determining whether the service has a dependency to another service; and

executing the service and the another service if the service has the dependency to another service.

15. The method of claim 14, comprising:

invoking lifecycle management to start the service and the another service to be executed and to stop the service and the another service if no other currently executing service is dependent on the service and the another service.

16. The method of claim 13, comprising:

receiving a service application; and

generate an exposed service application that is exposed to a plurality of different service bindings, wherein the exposed service application includes adaptors to provide a service using any of the plurality of different service bindings.

17. At least one non-transitory computer readable medium storing machine readable instructions that when executed perform instructions to:

receive information at a service request gateway;

determine whether the information is event data or a service request;

if the information is event data, send the event data to an event process module in a platform to process the event data according to predetermined services;

if the information is a service request,

send the service request to a service container module in the platform, and determine context data and a service to call for the request;

determine, by the service container module, if the service request is an asynchronous service request or a synchronous request;

if the service request is an asynchronous service request, send an acknowledgment to a service consumer sending the service request, wherein the acknowledgement comprises a reference ID for making a status request about service execution; and

if the service request is a synchronous service request, process the service request without sending the acknowledgment to the service consumer;

execute the service in the platform; and

send results of executing the service from the service container module to a service container via the service request gateway.

18. The at least one non-transitory computer readable medium of claim 17, wherein instructions to execute the service comprise instructions to:

determine whether the service has a dependency to another service; and

execute the service and the another service if the service has the dependency to another service.

19. The at least one non-transitory computer readable medium of claim 17, wherein the instructions comprise instructions to:

receive a service application; and

generate an exposed service application that is exposed to a plurality of different service bindings, wherein the exposed service application includes adaptors to provide a service using any of the plurality of different service bindings.