Refactored collector code to generalize Spool Writer
Refactord Code to generalize SpoolWriter
Applying review comments
Review comments incorporated
Updating code based on review comments
Passing Event name and serialization type to the processors
Have refactored the code to extract the parallel execution in a private method and calling from both the places. Also adjusted the close() as the executor was shutting down before the files were been processed
Replacing int with TimeSpan for executorShutdown period
Introduced event based flush and generalized the existing code for future spool processors.
replacing log level
Incorporated Review comments
Changed package naming convention and moved respective classes accordingly.
Introducing DB Processor layer
Incorporated review comments
Adding DB Module
Introducing Db Storage for Subscriptions
Applying review comments
Introduced Channel Event storage implementation
test case for Channel Event Storage
Updating code as per review comment