Complex event processing (CEP) adapters for CEP systems for receiving objects from a source and outputing objects to a sink

• US 8,392,936 B2
• Filed: 01/27/2012
• Issued: 03/05/2013
• Est. Priority Date: 10/21/2009
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Gerea, Ciprian, Krishnan, Ramkumar, Verona, Tomer, Raman, Balan Sethu, Sezgin, Beysim
• Primary Examiner(s): PEYTON, TAMMARA R
• Application Number:
  US13/360,548
• Publication Number:
  US 20120131599A1
• Time in Patent Office: 403 Days
• Field of Search: 719/318, 710/52, 710/104
• US Class Current: 719/318
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

Methods, systems, and computer-readable media are disclosed for implementing adapters for event processing systems. A particular system includes an input adapter configured to store event objects received from a source at an input queue. The system also includes a query engine configured to remove event objects from the input queue, to perform a query with respect to the removed event objects to generate result objects, and to insert result objects into an output queue. The system also includes an output adapter configured to remove result objects from the output queue and to transmit the result objects to a sink.

Claims

1. A computer-implemented method of operating a complex event processing (CEP) adapter, the method comprising:

initiating the CEP adapter based on an adapter factory class that includes data common to two or more of a point event model, an interval event model, and an edge event model;

receiving a start message at the CEP adapter;

executing a running state at the CEP adapter in response to the start message;

during execution of the running state, receiving an event object from a source;

attempting to execute a queue operation with respect to the event object;

when the queue operation is successful, remaining in the running state;

when the queue operation is unsuccessful, entering a suspended state, wherein the CEP adapter is configured to not perform the queue operation during the suspended state;

receiving a resume message while in the suspended state; and

terminating the suspended state and re-executing the running state in response to the resume message.

2. The computer-implemented method of claim 1, wherein the CEP adapter is a CEP input adapter.

3. The computer-implemented method of claim 2, wherein the CEP adapter is a CEP output adapter.

4. The computer-implemented method of claim 1, wherein the queue operation is one of an enqueue operation that inserts the event object into a queue and a dequeue operation that retrieves the event object from the queue.

5. The computer-implemented method of claim 1, wherein instantiating the adapter includes configuring the adapter based on an extensible markup language (XML) serializable configuration scheme.

6. One or more computer storage media not consisting of a propagated data signal and having computer-executable components providing a method of operating a complex event processing (CEP) adapter, the method comprising:

initiating the CEP adapter based on an adapter factory class that includes data common to two or more of a point event model, an interval event model, and an edge event model;

receiving a start message at the CEP adapter;

executing a running state at the CEP adapter in response to the start message;

during execution of the running state, receiving an event object from a source;

attempting to execute a queue operation with respect to the event object;

when the queue operation is successful, remaining in the running state;

when the queue operation is unsuccessful, entering a suspended state, wherein the CEP adapter is configured to not perform the queue operation during the suspended state;

receiving a resume message while in the suspended state; and

terminating the suspended state and re-executing the running state in response to the resume message.

7. The one or more computer storage media of claim 6, wherein the CEP adapter is a CEP input adapter.

8. The one or more computer storage media of claim 7, wherein the CEP adapter is a CEP output adapter.

9. The one or more computer storage media of claim 6, wherein the queue operation is one of an enqueue operation that inserts the event object into a queue and a dequeue operation that retrieves the event object from the queue.

10. The one or more computer storage media of claim 6, wherein instantiating the adapter includes configuring the adapter based on an extensible markup language (XML) serializable configuration scheme.

11. A computer implemented system comprising:

a processor; and

a memory communicatively coupled to the processor, the memory having computer-executable instructions that when executed by the processor, provide a method of operating a complex event processing (CEP) adapter, the method comprising;

initiating the CEP adapter based on an adapter factory class that includes data common to two or more of a point event model, an interval event model, and an edge event model;

receiving a start message at the CEP adapter;

executing a running state at the CEP adapter in response to the start message;

during execution of the running state, receiving an event object from a source;

attempting to execute a queue operation with respect to the event object;

when the queue operation is successful, remaining in the running state;

when the queue operation is unsuccessful, entering a suspended state, wherein the CEP adapter is configured to not perform the queue operation during the suspended state;

receiving a resume message while in the suspended state; and

terminating the suspended state and re-executing the running state in response to the resume message.

12. The computer implemented system of claim 11, wherein the CEP adapter is a CEP input adapter.

13. The computer implemented system of claim 12, wherein the CEP adapter is a CEP output adapter.

14. The computer implemented system of claim 11, wherein the queue operation is one of an enqueue operation that inserts the event object into a queue and a dequeue operation that retrieves the event object from the queue.

15. The computer implemented system of claim 11, wherein instantiating the adapter includes configuring the adapter based on an extensible markup language (XML) serializable configuration scheme.