Event-driven approach for collecting monitoring data of messaging systems

• US 9,135,093 B2
• Filed: 08/31/2012
• Issued: 09/15/2015
• Est. Priority Date: 08/31/2012
• Status: Active Grant

• Current Assignee: SAP SE
• Original Assignee: SAP SE
• Inventors: Boller, Stefan, Befort, Waldemar, Stoyanov, Tihomir, Henning, Steffen
• Primary Examiner(s): Ho, Andy
• Assistant Examiner(s): SEYE, ABDOU K
• Application Number:
  US13/601,241
• Publication Number:
  US 20140068629A1
• Time in Patent Office: 1,110 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: G06F 11/0709 in a distributed system consisting of a plurality of standalone computer nodes, e.g. clusters, client-server systems
• CPC Class Codes: G06F 11/0751 Error or fault detection not based on redundancy power supply failures G06F1/30; network fault management H04L41/06
• CPC Class Codes: G06F 11/30 Monitoring
• CPC Class Codes: G06F 11/3006 where the computing system is distributed, e.g. networked systems, clusters, multiprocessor systems multiprogramming arrangements G06F9/46; allocation of resources G06F9/50
• CPC Class Codes: G06F 11/3072 where the reporting involves data filtering, e.g. pattern matching, time or event triggered, adaptive or policy-based reporting
• CPC Class Codes: G06F 13/00 Interconnection of, or transfer of information or other signals between, memories, input/output devices or central processing units interface circuits for specific input/output devices G06F3/00 ; multiprogram control therefor G06F9/46; multiprocessor systems G06F15/16
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

The present disclosure relates to software, computer systems, and computer implemented methods for providing centralized process integration (PI) domain alert monitoring. One process includes identifying at least one alert rule at a central rules repository, the at least one alert rule associated with at least one message inter-communication within a process integration (PI) domain, where the PI domain includes at least one PI component, and where the message inter-communications within the PI domain occur between PI components. At least one alert consumer registration associated with at least one alert consumer system for an identified alert rule is identified. Information associated with the at least one identified alert rule from the central rules repository is distributed to the corresponding PI component associated with the message inter-communication linked to the alert rule and to the at least one registered alert consumer system.

Claims

1. A computer-implemented method performed by one or more processors for centralized management of alert rules, the method comprising:

identifying at least one alert rule at a central rules repository, the at least one alert rule associated with at least one message inter-communication within a process integration (PI) domain, wherein the PI domain includes at least one PI component, wherein the message inter-communications within the PI domain occur between PI components, wherein the at least one PI component contains a generic queue and one or more associated sub-queues generated based on at least one

identified at least one remote alert consumer registration associated with at least one remote alert consumer system for at least one of the identified alert rules at the central rules repository, wherein the generic queue and the at least one sub-queue are analyzed with a housekeeping algorithm using one or more housekeeping rules to maintain a size and age of the respective queues, where the housekeeping algorithm includes a determination of the size of the respective queues and the age of the at least one alert event included therein, and wherein the housekeeping algorithm creates a housekeeping event once a threshold determined from the one or more housekeeping rules is exceeded, the housekeeping event collecting and aggregating a subset of data and information included within alert messages remaining within a specific queue when the housekeeping event is created; and

distributing information associated with the at least one identified alert rule from the central rules repository to the at least one PI component associated with the at least one message inter-communication associated with the at least one alert rule and to the at least one alert consumer system associated with the identified at least one alert consumer registration, wherein the information includes information on one or more other alert consumer systems at which information associated with the at least one identified alert rule is made available, and wherein the one or more other alert consumer systems are monitored to identify and collect alert rule-relevant information associated with the at least one identified alert rule for further processing.

2. The method of claim 1, wherein the distributed information associated with the at least one alert rule from the central rules repository comprises a first set of distributed information distributed to the at least one PI component associated with the at least one message inter-communication and a second set of distributed information distributed to the at least one alert consumer system associated with the identified at least one alert consumer registration.

3. The method of claim 1, wherein in response to receiving the information associated with the at least one alert rule from the central rules repository, each of the at least one PI components associated with the at least one message inter-communication associated with the at least one alert rule evaluates the messages associated with a particular PI component based upon the at least one alert rule.

4. The method of claim 3, wherein an alert event is generated at the particular PI component in response to a message satisfying the at least one alert rule.

5. The method of claim 4, wherein the alert events are initially stored in the generic queue at the particular PI component.

6. The method of claim 5, wherein the particular PI component associated with a particular alert rule receives, from the central rules repository, information identifying the at least one alert consumer registration associated with the particular alert rule;

and further wherein, the particular PI component creates a sub-queue of the one or more associated sub-queues, the sub-queue specific to the at least one identified alert consumer registration.

7. The method of claim 6, further comprising:

analyzing the generic queue at the particular PI component to identify at least one alert event associated with the at least one alert consumer registration; and

moving a copy of the at least one identified alert event to the sub-queue specific to the at least one identified alert consumer registration.

8. The method of claim 7, wherein the at least one alert event is associated with at least two different alert consumer registrations wherein a copy of the at least one identified alert event is moved to at least two different sub-queues.

9. The method of claim 7, wherein the at least one identified alert event is removed from the generic queue after moving the copy of the at least one identified alert event.

10. A computer program product encoded on a non-transitory, tangible storage medium, the product comprising computer readable instructions for causing one or more processors to perform operations comprising:

identifying at least one alert rule at a central rules repository, the at least one alert rule associated with at least one message inter-communication within a process integration (PI) domain, wherein the PI domain includes at least one PI component, wherein the message inter-communications within the PI domain occur between PI components, wherein the at least one PI component contains a generic queue and one or more associated sub-queues generated based on at least one

identified at least one alert consumer registration associated with at least one remote alert consumer system for at least one of the identified alert rules at the central rules repository, wherein the generic queue and the at least one sub-queue are analyzed with a housekeeping algorithm using one or more housekeeping rules to maintain a size and age of the respective queues, where the housekeeping algorithm includes a determination of the size of the respective queues and the age of the at least one alert event included therein, and wherein the housekeeping algorithm creates a housekeeping event once a threshold determined from the one or more housekeeping rules is exceeded, the housekeeping event collecting and aggregating a subset of data and information included within alert messages remaining within a specific queue when the housekeeping event is created; and

distributing information associated with the at least one identified alert rule from the central rules repository to the at least one PI component associated with the at least one message inter-communication associated with the at least one alert rule and to the at least one alert consumer system associated with the identified at least one alert consumer registration, wherein the information includes information on one or more other alert consumer systems at which information associated with the at least one identified alert rule is made available, and wherein the one or more other alert consumer systems are monitored to identify and collect alert rule-relevant information associated with the at least one identified alert rule for further processing.

11. The computer program product of claim 10, wherein the distributed information associated with the at least one alert rule from the central rules repository comprises a first set of distributed information distributed to the at least one PI component associated with the at least one message inter-communication and a second set of distributed information distributed to the at least one alert consumer system associated with the identified at least one alert consumer registration.

12. The computer program product of claim 10, wherein in response to receiving the information associated with the at least one alert rule from the central rules repository, each of the at least one PI components associated with the at least one message inter-communication associated with the at least one alert rule evaluates the messages associated with a particular PI component based upon the at least one alert rule.

13. The computer program product of claim 12, wherein an alert event is generated at the particular PI component in response to a message satisfying the at least one alert rule.

14. The computer program product of claim 13, wherein the alert events are initially stored in the generic queue at the particular PI component.

15. The computer program product of claim 14, wherein the particular PI component associated with a particular alert rule receives, from the central rules repository, information identifying the at least one alert consumer registration associated with the particular alert rule;

and further wherein, the particular PI component creates a sub-queue of the one or more associated sub-queues, the sub-queue specific to the at least one identified alert consumer registration.

16. The computer program product of claim 15, further comprising:

analyzing the generic queue at the particular PI component to identify at least one alert event associated with the at least one alert consumer registration; and

moving a copy of the at least one identified alert event to the sub-queue specific to the at least one identified alert consumer registration.

17. The computer program product of claim 16, wherein the at least one alert event is associated with at least two different alert consumer registrations wherein a copy of the at least one identified alert event is moved to at least two different sub-queues.

18. The computer program product of claim 16, wherein the at least one identified alert event is removed from the generic queue after moving the copy of the at least one identified alert event.

19. A system, comprising:

one or more computers and a computer-readable medium coupled to the one or more computers having instructions stored thereon which, when executed by the one or more computers, cause the one or more computers to perform operations comprising;

identifying at least one alert rule at a central rules repository, the at least one alert rule associated with at least one message inter-communication within a process integration (PI) domain, wherein the PI domain includes at least one PI component, wherein the message inter-communications within the PI domain occur between PI components, wherein the at least one PI component contains a generic queue and one or more associated sub-queues generated based on at least one

identified at least one alert consumer registration associated with at least remote one alert consumer system for at least one of the identified alert rules at the central rules repository, wherein the generic queue and the at least one sub-queue are analyzed with a housekeeping algorithm using one or more housekeeping rules to maintain a size and age of the respective queues, where the housekeeping algorithm includes a determination of the size of the respective queues and the age of the at least one alert event included therein, and wherein the housekeeping algorithm creates a housekeeping event once a threshold determined from the one or more housekeeping rules is exceeded, the housekeeping event collecting and aggregating a subset of data and information included within alert messages remaining within a specific queue when the housekeeping event is created; and

distributing information associated with the at least one identified alert rule from the central rules repository to the at least one PI component associated with the at least one message inter-communication associated with the at least one alert rule and to the at least one alert consumer system associated with the identified at least one alert consumer registration, wherein the information includes information on one or more other alert consumer systems at which-information associated with the at least one identified alert rule is made available, and wherein the one or more other alert consumer systems are monitored to identify and collect alert rule-relevant information associated with the at least one identified alert rule for further processing.