update twisted example

pika · Oct 10, 2017 · 6baad8e · 6baad8e · sanderfoobar · Oct 21, 2017
1 parent 046600d
commit 6baad8e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/examples/twisted_service.py b/examples/twisted_service.py
@@ -90,7 +90,7 @@ def read(self, exchange, routing_key, callback):
     def setup_read(self, exchange, routing_key, callback):
         """This function does the work to read from an exchange."""
         if not exchange == '':
-            yield self.channel.exchange_declare(exchange=exchange, type='topic', durable=True, auto_delete=False)
+            yield self.channel.exchange_declare(exchange=exchange, exchange_type='topic', durable=True, auto_delete=False)
 
         self.channel.queue_declare(queue=routing_key, durable=True)
 
@@ -127,7 +127,7 @@ def send(self):
     def send_message(self, exchange, routing_key, msg):
         """Send a single message."""
         log.msg('%s (%s): %s' % (exchange, routing_key, repr(msg)), system='Pika:=>')
-        yield self.channel.exchange_declare(exchange=exchange, type='topic', durable=True, auto_delete=False)
+        yield self.channel.exchange_declare(exchange=exchange, exchange_type='topic', durable=True, auto_delete=False)
         prop = spec.BasicProperties(delivery_mode=2)
         try:
             yield self.channel.basic_publish(exchange=exchange, routing_key=routing_key, body=msg, properties=prop)