Event processing
First Claim
1. A computer-implemented method for processing an update event of a distributed processing environment, the distributed processing environment comprising a flow engine adapted to implement a plurality of processing flows, the method comprising:
- separating the plurality of processing flows into a plurality of flow groups, each flow group having a respective identifier;
associating the identifier of each flow group with a respective topic;
based on detecting the occurrence of an update event in an application or service of the distributed processing environment, publishing a message to a topic based on the update event;
based on the publishing, matching, by a messaging engine, the message topic with an identifier of the flow group associated with the topic, the matching being with reference to a database of mappings between flow groups and topics;
based on the matching, by the messaging engine, providing the message and identifier to the flow engine, wherein the messaging engine and the flow engine are separate engines; and
processing by the flow engine the update event using a processing flow of the flow group having the identifier of the message, wherein the flow engine is stateless and scalable, and able to run multiple processing flows concurrently.
1 Assignment
0 Petitions
Accused Products
Abstract
A facility for processing an event of a distributed processing environment is provided. The facility includes separating a plurality of processing flows into a plurality of flow groups, each flow group having a respective identifier. The identifier of each flow group is then associated with a respective topic. Based on the occurrence of an event, a message having a topic based on the event is published along with the identifier of the flow group associated with the topic. A processing flow of the flow group having the identifier of the message may then be used to process the event.
18 Citations
20 Claims
-
1. A computer-implemented method for processing an update event of a distributed processing environment, the distributed processing environment comprising a flow engine adapted to implement a plurality of processing flows, the method comprising:
-
separating the plurality of processing flows into a plurality of flow groups, each flow group having a respective identifier; associating the identifier of each flow group with a respective topic; based on detecting the occurrence of an update event in an application or service of the distributed processing environment, publishing a message to a topic based on the update event; based on the publishing, matching, by a messaging engine, the message topic with an identifier of the flow group associated with the topic, the matching being with reference to a database of mappings between flow groups and topics; based on the matching, by the messaging engine, providing the message and identifier to the flow engine, wherein the messaging engine and the flow engine are separate engines; and processing by the flow engine the update event using a processing flow of the flow group having the identifier of the message, wherein the flow engine is stateless and scalable, and able to run multiple processing flows concurrently. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8)
-
-
9. A computer program product for processing an update event of a distributed processing environment, the distributed processing environment comprising a flow engine adapted to implement a plurality of processing flows, the computer program product comprising:
a non-transitory computer readable storage medium having program instructions embodied therewith, the program instructions executable by a processing unit to cause the processing unit to perform a method comprising; separating the plurality of processing flows in a plurality of flow groups, each flow group having a respective identifier; associating the identifier of each flow group with a respective topic; based on detecting the occurrence of an update event in an application or service of the distributed processing environment, publishing a message to a topic based on the update event; based on the publishing, matching, by a messaging engine, the message topic with an identifier of the flow group associated with the topic, the matching being with reference to a database of mappings between flow groups and topics; based on the matching, by the messaging engine, providing the message and identifier to the flow engine, wherein the messaging engine and the flow engine are separate engines; and processing by the flow engine the update event using a processing flow of the flow group having the identifier of the message, wherein the flow engine is stateless and scalable, and able to run multiple processing flows concurrently. - View Dependent Claims (10, 11, 12, 13, 14, 15)
-
16. A system for processing an update event of a distributed processing environment, the distributed processing environment comprising a flow engine adapted to implement a plurality of processing flows, the system comprising:
-
a memory; and a processor communicatively coupled to the memory, wherein the system performs a method comprising; separating the plurality of processing flows into a plurality of flow groups, each flow group having a respective identifier; associating the identifier of each flow group with a respective topic; based on detecting the occurrence of an update event in an application or service of the distributed processing environment, publishing a message to a topic based on the update event; based on the publishing, matching, by a messaging engine, the message topic with an identifier of the flow group associated with the topic, the matching being with reference to a database of mappings between flow groups and topics; based on the matching, by the messaging engine, providing the message and identifier to the flow engine, wherein the messaging engine and the flow engine are separate engines; and processing by the flow engine the update event using a processing flow of the flow group having the identifier of the message, wherein the flow engine is stateless and scalable, and able to run multiple processing flows concurrently. - View Dependent Claims (17, 18, 19, 20)
-
Specification