Manage daemon for event reconciliation in a computer system
In an example embodiment, multiple different categories of events from an Enterprise application are separated and processed by different daemons. This allows events of a first category, such as business events, to be processed separately from events of a second category, such as configuration events. This provides the benefits of stable event processing, additional monitoring functionality, and specialized error handling.
1. A system comprising:
at least one hardware processor; and
a computer-readable medium storing instructions that, when executed by the at least one hardware processor, cause the at least one hardware processor to perform operations comprising:
launching a subscribe daemon on a computer server, the subscribe daemon monitoring a first topic or channel on a message broker for published events of a first event category to the first topic or channel;
launching a manage daemon on the computer server, the manage daemon monitoring the first topic or channel on the message broker for published event of a second event category;
receiving, by the subscribe daemon, a first event, the first event belonging to the first category, published to the first topic or channel on the message broker;
receiving by the manage daemon, a second event, the second event belonging to the second category, published to the first topic or channel on the message broker; and
causing the subscribe daemon to process the first event and the manage daemon to process the second event, the subscribe daemon performing its processing independently of the processing of the manage daemon.
2. The system of claim 1 , wherein the manage daemon is connected to the message broker via a separate link than the subscribe daemon is connected to the message broker.
3. The system of claim 2 , wherein the separate link is an AMQP link.
4. The system of claim 1 , wherein the processing of the first event by the subscribe daemon is performed by writing the first event to an inbound event queue, which is monitored by a consume daemon, and wherein the consume daemon retrieves the first event from the event queue and publishes it to a first subscribing service.
5. The system of claim 4 , wherein the processing of the second event by the manage daemon is performed by writing the second event to the inbound event queue, and wherein the consume daemon retrieves the second event from the event queue and processes a change to the topic or channel based on the second event.
6. The system of claim 4 , wherein the processing of the second event by the manage daemon is performed by writing the second event to a consume daemon contained within the manage daemon, wherein the consume daemon processes a change to the topic or channel based on the second event.
7. The system of claim 1 , wherein the second category is configuration events.
8. A method comprising:
launching a subscribe daemon on a computer server, the subscribe daemon monitoring a first topic or channel on a message broker for published events of a first event category to the first topic or channel;
launching a manage daemon on the computer server, the manage daemon monitoring the first topic or channel on the message broker for published event of a second event category;
receiving, by the subscribe daemon, a first event, the first event belonging to the first category, published to the first topic or channel on the message broker;
receiving by the manage daemon, a second event, the second event belonging to the second category, published to the first topic or channel on the message broker; and
causing the subscribe daemon to process the first event and the manage daemon to process the second event, the subscribe daemon performing its processing independently of the processing of the manage daemon.
9. The method of claim 8 , wherein the manage daemon is connected to the message broker via a separate link than the subscribe daemon is connected to the message broker.
10. The method of claim 9 , wherein the separate link is an AMQP link.
11. The method of claim 8 , wherein the processing of the first event by the subscribe daemon is performed by writing the first event to an inbound event queue, which is monitored by a consume daemon, and wherein the consume daemon retrieves the first event from the event queue and publishes it to a first subscribing service.
12. The method of claim 11 , wherein the processing of the second event by the manage daemon is performed by writing the second event to the inbound event queue, and wherein the consume daemon retrieves the second event from the event queue and processes a change to the topic or channel based on the second event.
13. The method of claim 11 , wherein the processing of the second event by the manage daemon is performed by writing the second event to a consume daemon contained within the manage daemon, wherein the consume daemon processes a change to the topic or channel based on the second event.
14. The method of claim 8 , wherein the second category is configuration events.
15. A non-transitory machine-readable medium storing instructions which, when executed by one or more processors, cause the one or more processors to perform operations comprising:
launching a subscribe daemon on a computer server, the subscribe daemon monitoring a first topic or channel on a message broker for published events of a first event category to the first topic or channel;
launching a manage daemon on the computer server, the manage daemon monitoring the first topic or channel on the message broker for published event of a second event category;
receiving, by the subscribe daemon, a first event, the first event belonging to the first category, published to the first topic or channel on the message broker;
receiving by the manage daemon, a second event, the second event belonging to the second category, published to the first topic or channel on the message broker; and
causing the subscribe daemon to process the first event and the manage daemon to process the second event, the subscribe daemon performing its processing independently of the processing of the manage daemon.
16. The non-transitory machine-readable medium of claim 15 , wherein the manage daemon is connected to the message broker via a separate link than the subscribe daemon is connected to the message broker.
17. The non-transitory machine-readable medium of claim 16 , wherein the separate link is an AMQP link.
18. The non-transitory machine-readable medium of claim 15 , wherein the processing of the first event by the subscribe daemon is performed by writing the first event to an inbound event queue, which is monitored by a consume daemon, and wherein the consume daemon retrieves the first event from the event queue and publishes it to a first subscribing service.
19. The non-transitory machine-readable medium of claim 18 , wherein the processing of the second event by the manage daemon is performed by writing the second event to the inbound event queue, and wherein the consume daemon retrieves the second event from the event queue and processes a change to the topic or channel based on the second event.
20. The non-transitory machine-readable medium of claim 18 , wherein the processing of the second event by the manage daemon is performed by writing the second event to a consume daemon contained within the manage daemon, wherein the consume daemon processes a change to the topic or channel based on the second event.