I added a second cache called test_coinc_cache and a second alert publisher which is set to publish alerts to the "test connection topic" and not the main alert topic.
Except for long term storage both instances and publications are doing the same things.
Once a message in the stream is read. The contents are first searched by the command handler, which returns True if the message is indeed a coincidence tier message. (if not, check if it is a known command, or significance tier or etc. and returns False)
The new part starts here. If the message is sent with a is_test=True flag, coincidence decider starts using the test cache and runs the coincidence search with this cache. The main cache still remains but it is not used at this time.
If a coincidence is found for this test cache, then it calls the alert publisher which publishes the alerts to the test connection topic.
I added a second cache called
test_coinc_cache
and a second alert publisher which is set to publish alerts to the "test connection topic" and not the main alert topic.Except for long term storage both instances and publications are doing the same things.
Once a message in the stream is read. The contents are first searched by the command handler, which returns True if the message is indeed a coincidence tier message. (if not, check if it is a known command, or significance tier or etc. and returns False)
The new part starts here. If the message is sent with a
is_test=True
flag, coincidence decider starts using the test cache and runs the coincidence search with this cache. The main cache still remains but it is not used at this time. If a coincidence is found for this test cache, then it calls the alert publisher which publishes the alerts to the test connection topic.