Contains basic implemnentation of the following 1. Publishing data into a queue continuously 2. Reading from the queue simultaneously from different subscribers 3. Adjusting the size of the queue dynamically to avoid data overloading // To execute the code use "go run .go