header --> properties

Author: majek

python/emit_log_topic.py

@@ -10,7 +10,7 @@
 
 print ' [*] Waiting for messages. To exit press CTRL+C'
 
-def callback(ch, method, header, body):
+def callback(ch, method, properties, body):
     print " [x] Received %r" % (body,)
 
 channel.basic_consume(callback,

python/receive.py

@@ -16,7 +16,7 @@
 
 print ' [*] Waiting for logs. To exit press CTRL+C'
 
-def callback(ch, method, header, body):
+def callback(ch, method, properties, body):
     print " [x] %r" % (body,)
 
 channel.basic_consume(callback,

python/receive_logs.py

@@ -24,7 +24,7 @@
 
 print ' [*] Waiting for logs. To exit press CTRL+C'
 
-def callback(ch, method, header, body):
+def callback(ch, method, properties, body):
     print " [x] %r:%r" % (method.routing_key, body,)
 
 channel.basic_consume(callback,

python/receive_logs_direct.py

@@ -24,7 +24,7 @@
 
 print ' [*] Waiting for logs. To exit press CTRL+C'
 
-def callback(ch, method, header, body):
+def callback(ch, method, properties, body):
     print " [x] %r:%r" % (method.routing_key, body,)
 
 channel.basic_consume(callback,

python/receive_logs_topic.py

@@ -9,7 +9,7 @@
 channel.queue_declare(queue='task_queue', durable=True)
 print ' [*] Waiting for messages. To exit press CTRL+C'
 
-def callback(ch, method, header, body):
+def callback(ch, method, properties, body):
     print " [x] Received %r" % (body,)
     time.sleep( body.count('.') )
     print " [x] Done"