adding unit test and fix for clearing request queue for subscribe worker before adding more requests
adding more unit tests for testing in multithreaded environment