public function consume($config, callable $callable)
    {
        $this->ProcessManager->handleKillSignals();
        $this->eventManager()->attach([$this, 'signalHandler'], 'CLI.signal', ['priority' => 100]);

        $this->_consume(Queue::consume($config), $callable);
    }
public function consume($config, callable $callable)
    {
        $this->ProcessManager->handleKillSignals();
        $this->eventManager()->attach([$this, 'signalHandler'], 'CLI.signal', ['priority' => 100]);

        $this->_consume(Queue::consume($config), $callable);
    }
public function consume ( $ config , callable $ callable ) { $ this -> ProcessManager -> handleKillSignals ( ) ; $ this -> eventManager ( ) -> attach ( [ $ this , 'signalHandler' ] , 'CLI.signal' , [ 'priority' => 100 ] ) ; $ this -> _consume ( Queue :: consume ( $ config ) , $ callable ) ; }
Consume a queue by the RabbitMQ queue configuration

@param string $config
@param callable $callable
@return void
Consume a queue by the RabbitMQ queue configuration