Details
-
New Feature
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
Add basic unit testing framework for DagActionStoreChangeMonitor.processMessage() function which is used for processing launch, kill, and resume flow action events. This is a crucial piece of functionality used to launch events, so it needs to be resilient to malformed message types and handle them without interrupting the thread processing the queue. The main functionality we seek to test is to ensure heartbeat type messages or messages with null dag action types are handled without throwing a NullPointerException. The unit tests are rudimentary other than the aforementioned functionality, mocking all related classes so their states and the actual result of processing the message is not validated at the moment.