Class | Ruote::Tracker |
In: |
lib/ruote/svc/tracker.rb
|
Parent: | Object |
The tracker service is used by the "listen" expression. This services sees all the msg processed by a worker and triggers any listener interested in a particular msg.
Look at the ListenExpression for more details.
Adds a tracker (usually when a ‘listen’ expression gets applied).
The tracker_id may be nil (one will then get generated).
Returns the tracker_id.
Removes a tracker (usually when a ‘listen’ expression replies to its parent expression or is cancelled).
The method behind on_pre_msg and on_msg. Filters msgs against trackers. Triggers trackers if there is a match.
Returns the trackers currently registered.
Note: this is called from on_pre_msg and on_msg, hence two times for a single msg. We trust the storage implementation to cache it for us.