Queue Management

- Asynchronous initialization of Consumer -> Responder

- Timeout of consumer will restart the process

- Separated broadcast() from publish()
Merge branch 'develop' of codebasehq.com:playgen/celar/datacon into develop