EVENT PROCESSING
First Claim
1. A computer-implemented method for processing an 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 the occurrence of an event in an application or service, publishing a message having a topic based on the event, the message including the identifier of the flow group associated with the topic; and
using a processing flow of the flow group having the identifier of the message to process the event.
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.
20 Citations
20 Claims
-
1. A computer-implemented method for processing an 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 the occurrence of an event in an application or service, publishing a message having a topic based on the event, the message including the identifier of the flow group associated with the topic; and using a processing flow of the flow group having the identifier of the message to process the event. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8)
-
-
9. A computer program product for processing an 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 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 the occurrence of an event in an application or service, publishing a message having a topic based on the event, the message including the identifier of the flow group associated with the topic; and using a processing flow of the flow group having the identifier of the message to process the event. - View Dependent Claims (10, 11, 12, 13, 14, 15)
-
16. A system for processing an 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 the occurrence of an event in an application or service, publishing a message having a topic based on the event, the message including the identifier of the flow group associated with the topic; and using a processing flow of the flow group having the identifier of the message to process the event. - View Dependent Claims (17, 18, 19, 20)
-
Specification