Right now only single goroutine kicks off per command, Implement a worker pool where workers will be assigned for routing msg between services.