master
connect
public function connect(array $config) { $connection = new AMQPStreamConnection( $config['host'], $config['port'],