Caché Publisher - Subscriber
The purpose of this repository is to provide a simple example of Publisher-Subscriber model implemented using InterSystems Caché.
This example came out of a session which discussed ways of processing work asynchronously using persistent queues.
Run the code
; create events and subscriber jobs
; send some messages to channels
; show log
Caché Event API is used to let the subscriber processes sleep until they are notified.
- Manager - handles core operations such as adding subscribers, terminate all subscriber jobs, etc.
- Publisher - generic publisher, provides a basic Send operation which notifies a subscriber that a message is ready.
- Subscriber - generic subscriber, all subscriber must extend from this.
The following classes provides an example of how the main classes could be used, in this case there are two subscribers:
SubPatient which handles Patient related messages.
SubDummy which handles dummy messages.
After running the example, the log stored in ^PubSub.Log global will look similar to this:
There are several points of this example that can be discussed as an exercise:
Caché Event API vs Semaphores
$system.Event (Caché Event API) can only wait / wake up resources on the same system (not networking supported).
- It would be interesting implementing this same model using $system.Semaphore over an ECP scenario.
Multiple types of subscribers
- In IAT.PubSub.Publisher:Send() method, it simply creates a message header, save it to queue and send a signal to one of the subscribers.
- It would be interesting allowing more than one type of subscriber per channel. In this case, the Send() method should create several message headers and signal the different types of configured subscribers.
Have a look at InterSystems Developer Community to learn about InterSystems technology, sharing solutions and staying up-to-date on the latest developments.
This example was published in https://community.intersystems.com/post/simple-systemevent-examples