Copy messages from the correct queue
Implement blpop handler (mq -> tcp path)