Support Rabbitmq Exchange types about bowler HOT 1 CLOSED

public function __construct(Connection $connection, $exchangeName, $exchangeType, $queueName, $routingKey, $passive = false, $durable = true, $autoDelete = false, $deliveryMode = 2)
{
   $this->connection = $connection;
   $this->exchangeName = $exchangeName;
   $this->exchangeType = $exchangeType;
   $this->queueName = $queueName;
   $this->passive = $passive;
   $this->durable = $durable;
   $this->autoDelete = $autoDelete;
   $this->deliveryMode = $deliveryMode;
   $this->routingKey = $routingKey;   //Since these should match
   $this->bindingKey = $routingKey;   //Since these should match
}

public function publish($data)
{
   $this->connection->getChannel()->exchange_declare($this->exchangeName, $this->exchangeType, $this->passive, $this->durable, $this->autoDelete);

   $this->connection->getChannel()->queue_declare($this->queueName, $this->passive, $this->durable, false, $this->autoDelete);

   $this->connection->getChannel()->queue_bind($this->queueName, $this->exchangeName, $this->bindingKey);

   $msg = new AMQPMessage($data, ['delivery_mode' => $this->deliveryMode]);

   $this->connection->getChannel()->basic_publish($msg, $this->exchangeName, $this->routingKey);
}

public function __construct(Connection $connection, $exchangeName, $exchangeType, $queueName, $bindingKey, $passive = false, $durable = true, $autoDelete = false, $deliveryMode = 2)
{
   $this->connection = $connection;
   $this->exchangeName = $exchangeName;
   $this->exchangeType = $exchangeType;
   $this->queueName = $queueName;
   $this->passive = $passive;
   $this->durable = $durable;
   $this->autoDelete = $autoDelete;
   $this->deliveryMode = $deliveryMode;
   $this->bindingKey = $bindingKey;
}

public function listenToQueue($handlerClass, ExceptionHandler $exceptionHandler)
{
   $this->connection->getChannel()->exchange_declare($this->exchangeName, $this->exchangeType, $this->passive, $this->durable, $this->autoDelete);

   $this->connection->getChannel()->queue_declare($this->queueName, $this->passive, $this->durable, false, $this->autoDelete);

   $this->connection->getChannel()->queue_bind($this->queueName, $this->exchangeName, $this->bindingKey);

$handler = new $handlerClass;

$callback = function ($msg) use ($handler, $exceptionHandler) {
   //
};

$this->connection->getChannel()->basic_qos(null, 1, null);
$this->connection->getChannel()->basic_consume($queue_name, '', false, false, false, false, $callback);

while (count($this->connection->getChannel()->callbacks)) {
    $this->connection->getChannel()->wait();
}
}