Fix call with deprecated arg

This commit is contained in:
Lucas Bickel 2018-07-06 12:12:39 +02:00
parent cc18596384
commit da64166fa5
1 changed files with 1 additions and 1 deletions

View File

@ -110,7 +110,7 @@ class MessageListener:
port=self._port, virtual_host=self._vhost,
credentials=pika.credentials.PlainCredentials(self._username, self._password)))
self._channel = self._connection.channel()
self._channel.exchange_declare(exchange=EXCHANGE, type=EXCHANGE_TYPE, durable=True)
self._channel.exchange_declare(exchange=EXCHANGE, exchange_type=EXCHANGE_TYPE, durable=True)
result = self._channel.queue_declare(queue=QUEUE, durable=True)
self._channel.queue_bind(exchange=EXCHANGE, queue=QUEUE, routing_key=ROUTING_KEY)