Methods and systems for event management

Abstract

A method for an index map-based event system includes receiving at least one subscription rule; processing the at least one subscription rule to determine an index map generation; generating an index map based on the determination; dynamically inserting into a received event, properties of the index map; and sending the modified event to a transport layer for dispatching. A method for dynamic property insertion in an event system includes receiving at least one subscription rule, each of the at least one subscription rule having a set of filter rules; generating an index map based on the filter rules; and annotating properties of a received event with properties referenced the index map correlating to characteristics of the received event. A device is configured to execute the methods disclosed herein. A system is configured to execute the methods disclosed herein.

1 . A method comprising, by an event system:
 receivingat least one subscription rule from a user input interface system;   processingthe at least one subscription rule, the processing including inspecting a property or an attribute value of the at least one subscription rule;   generatingan index map based on the processing;   dynamically insertinginto an event message received from an event producer, in response to receiving the event message, properties of the index map to make a modified event message; and   sendingthe modified event message.   
     
     
         2 . The method of  claim 1  wherein the index map contains event correlated properties including at least one of:
 transport layer dispatch properties; and 
 query process properties. 
 
     
     
         3 . The method of  claim 1  wherein which properties of the index map are to be dynamically inserted into the received event message is determined by comparing the index map with a source type identifier of the received event message. 
     
     
         4 . The method of  claim 1  wherein the sending comprising sending the modified event message to a transport layer for dispatching. 
     
     
         5 . The method of  claim 1  further comprising querying, by the system, a transport layer for event subscriptions based on subscription rules. 
     
     
         6 . The method of  claim 5  further comprising dispatching, by a dispatch service, the modified event message based on a result of the querying. 
     
     
         7 . The method of  claim 1  wherein the at least one subscription rule includes at least one filter rule, the index map being generated based on the at least one filter rule. 
     
     
         8 . A method comprising:
 receiving, by a system, at least one subscription rule from a user input interface system, each of the at least one subscription rule having a set of filter rules;   generating, by the system, an index map based on the set of filter rules; and   annotating, by the system, properties of a received event message with properties referenced in the index map correlating to characteristics of the received event message, the event message received from an event producer.   
     
     
         9 . The method of  claim 8  wherein the characteristics include at least one of: an event generation system;
 an event generation application; 
 an event generation service; 
 an event consumption system; 
 an event consumption application; or 
 an event consumption service. 
 
     
     
         10 . The method of  claim 8  further comprising sending, by the system, the annotated event message to a transport layer for dispatching. 
     
     
         11 . The method of  claim 10  further comprising querying, by the system, the transport layer by event target subscription for subscription delivery. 
     
     
         12 . A system comprising at least one processor and memory storing instructions for execution by the at least one processor to implement:
 receive at least one subscription rule from a user input interface system, the at least one subscription rule having a set of filter rules;   generate an index map based on the set of filter rules;   receive an event message from an event producer; and   annotate properties of the received event message with properties referenced the index map correlating to characteristics of the received event message.   
     
     
         13 . The system of  claim 12  wherein the index map contains event correlated properties including at least one of:
 transport layer dispatch properties; and 
 query process properties. 
 
     
     
         14 . The system of  claim 12  wherein which properties of the index map are to be dynamically inserted into the received event message is determined by comparing the index map with a source type identifier of the received event message. 
     
     
         15 . The system of  claim 12  wherein the memory further stores instructions for execution by the at least one processor to implement:
 query a transport layer for event subscriptions based on subscription rules. 
 
     
     
         16 . The system of  claim 15  wherein the memory further stores instructions for execution by the at least one processor to implement:
 dispatch the annotated event message based on a result of the querying. 
 
     
     
         17 . The system of  claim 12  wherein the at least one subscription rule includes at least one filter rule. 
     
     
         18 . The system of  claim 12  wherein the characteristics include at least one of: an event generation system;
 an event generation application; 
 an event generation service; 
 an event consumption system; 
 an event consumption application; or 
 an event consumption service. 
 
     
     
         19 . The system of  claim 12  wherein the memory further stores instructions for execution by the at least one processor to implement: send the annotated event message to a transport layer for dispatching. 
     
     
         20 . The system of  claim 19  wherein the memory further stores instructions for execution by the at least one processor to implement: query, the transport layer by event target subscription for subscription delivery.