Concurrency in event processing networks for event server
First Claim
Patent Images
1. A system for implementing an event processing network, comprising:
- a computer which includes a microprocessor;
an event server which executes on the computer and runs an event driven application that implements an event processing network (EPN), including one or more services, wherein the EPN is defined by an EPN assembly file that indicates a plurality of event sources, event sinks, event processors, and stream components, which are used to process events as part of the event driven application, and whereineach event processor is associated with its own configuration file, written in a markup language, and user-defined event processing and temporal constraint rules,the structure of each configuration file is defined by one or more schema documents, which define common elements that are shared with other configuration files and elements that are specific to the enclosing configuration file,the configuration file contains a top-level root element which in turn contains one or more sub-elements,each of the sub-elements contains a set of configuration data for the event processor,each stream functions as a virtual channel connecting one or more event sources, event sinks and event processors, andeach event processor executes its user-defined processing rules against one or more streams;
a plurality of adapters, each of which provides an interface that enables incoming data to be received at the event server and converted into event types that the event driven application understands;
wherein the EPN as defined by its assembly file further includes that at least two of the event processors should operate concurrently to operate on one or more input streams; and
wherein upon receiving the incoming data from the one or more input streams via the event sources, the event server controls the flow of events so that the events are processed concurrently, including duplicating events as appropriate for concurrent processing by each event processor.
2 Assignments
0 Petitions
Accused Products
Abstract
An event server running an event driven application implementing an event processing network. The event processing network can include at least one processor to implement a rule on at least one input stream. The event processing network can define concurrent operation of at least two components of the event processing networks.
-
Citations
23 Claims
-
1. A system for implementing an event processing network, comprising:
-
a computer which includes a microprocessor; an event server which executes on the computer and runs an event driven application that implements an event processing network (EPN), including one or more services, wherein the EPN is defined by an EPN assembly file that indicates a plurality of event sources, event sinks, event processors, and stream components, which are used to process events as part of the event driven application, and wherein each event processor is associated with its own configuration file, written in a markup language, and user-defined event processing and temporal constraint rules, the structure of each configuration file is defined by one or more schema documents, which define common elements that are shared with other configuration files and elements that are specific to the enclosing configuration file, the configuration file contains a top-level root element which in turn contains one or more sub-elements, each of the sub-elements contains a set of configuration data for the event processor, each stream functions as a virtual channel connecting one or more event sources, event sinks and event processors, and each event processor executes its user-defined processing rules against one or more streams; a plurality of adapters, each of which provides an interface that enables incoming data to be received at the event server and converted into event types that the event driven application understands; wherein the EPN as defined by its assembly file further includes that at least two of the event processors should operate concurrently to operate on one or more input streams; and wherein upon receiving the incoming data from the one or more input streams via the event sources, the event server controls the flow of events so that the events are processed concurrently, including duplicating events as appropriate for concurrent processing by each event processor. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A non-transitory computer readable storage medium, including instructions stored thereon, which when read and executed by one or more computers, cause the one or more computers to perform the steps comprising:
-
providing an event server which executes on the computer and runs an event driven application that implements an event processing network (EPN), including one or more services, wherein the EPN is defined by an EPN assembly file that indicates a plurality of event sources, event sinks, event processors and stream components, which are used to process events as part of the event driven application, and wherein each event processor is associated with its own configuration file, written in a markup language, and user-defined event processing and temporal constraint rules, the structure of each configuration file is defined by one or more schema documents, which define common elements that are shared with other configuration files and elements that are specific to the enclosing configuration file, the configuration file contains a top-level root element which in turn contains one or more sub-elements, each of the sub-elements contains a set of configuration data for the event processor, each stream functions as a virtual channel connecting one or more event sources, event sinks and event processors, and each event processor executes its user-defined processing rules against one or more streams; providing a plurality of adapters, each of which provides an interface that enables incoming data to be received at the event server and converted into event types that the event driven application understands; wherein the EPN as defined by its assembly file further includes further includes that at least two of the event processors should operate concurrently to operate on one or more input streams; and wherein upon receiving the incoming data from the one or more input streams via the event sources, the event server controls the flow of events so that the events are processed concurrently, including duplicating events as appropriate for concurrent processing by each event processor. - View Dependent Claims (13, 14, 15, 16, 17, 18, 19, 20, 21, 22)
-
-
23. A method of implementing an event processing network, comprising:
-
providing an event server which executes on a computer and runs an event driven application that implements an event processing network (EPN), including one or more services, wherein the EPN is defined by an EPN assembly file that indicates a plurality of event sources, event sinks, event processors and stream components, which are used to process events as part of the event driven application, and wherein each event processor is associated with its own configuration file, written in a markup language, and user-defined event processing and temporal constraint rules, the structure of each configuration file is defined by one or more schema documents, which define common elements that are shared with other configuration files and elements that are specific to the enclosing configuration file, the configuration file contains a top-level root element which in turn contains one or more sub-elements, each of the sub-elements contains a set of configuration data for the event processor, each stream functions as a virtual channel connecting one or more event sources, event sinks and event processors, and each event processor executes its user-defined processing rules against one or more streams; providing a plurality of adapters, each of which provides an interface that enables incoming data to be received at the event server and converted into event types that the event driven application understands; wherein the EPN as defined by its assembly file further includes that at least two of the event processors should operate concurrently to operate on one or more input streams; and wherein upon receiving the incoming data from the one or more input streams via the event sources, the event server controls the flow of events so that the events are processed concurrently, including duplicating events as appropriate for concurrent processing by each event processor.
-
Specification