A simple multi-threaded-message-queue with multiple producer and consumers. Queue can have more than one topic and more than one partitions.