public function addConsumer($queue, ConsumerInterface $consumer, $priority = 0)
    {
        $this->messageDispatcher->addListener($queue, array($consumer, 'consume'), $priority);
    }
public function addConsumer($queue, ConsumerInterface $consumer, $priority = 0)
    {
        $this->messageDispatcher->addListener($queue, array($consumer, 'consume'), $priority);
    }
public function addConsumer ( $ queue , ConsumerInterface $ consumer , $ priority = 0 ) { $ this -> messageDispatcher -> addListener ( $ queue , array ( $ consumer , 'consume' ) , $ priority ) ; }
Adds a consumer for messages from the given queue name

@param string            $queue
@param ConsumerInterface $consumer
@param int               $priority

@return void
Adds a consumer for messages from the given queue name