Message Queue with consumers and producers is completed

// done: /1/ producers: // Producers can connect to server // topic will created automatically if topic is not found // producers can start pushing messages to the topic /2/consumers: // Consumers can connect to server // consumers can subscribe and unsubscribe to multiple topics // consumers will start recieving all the messages in a topic once subscribed // consumers offset number is maintained to send only // the latest messages whwn new messages are published to the topic

// todo: /1/ Need to add consumer groups /2/ Need to ad commit and retention period to messages