Use print function syntax, in examples

examples/consume.py

@@ -6,11 +6,11 @@ def on_message(channel, method_frame, header_frame, body):
     if body.startswith("queue:"):
         queue = body.replace("queue:", "")
         key = body + "_key"
-        print "Declaring queue %s bound with key %s" %(queue, key)
+        print("Declaring queue %s bound with key %s" %(queue, key))
         channel.queue_declare(queue=queue, auto_delete=True)
         channel.queue_bind(queue=queue, exchange="test_exchange", routing_key=key)
     else:
-        print "Message body", body
+        print("Message body", body)
 
     channel.basic_ack(delivery_tag=method_frame.delivery_tag)
 

examples/consumer_queued.py

@@ -1,22 +1,22 @@
 #!/usr/bin/python
 # -*- coding: utf-8 -*-
 
-import pika    
+import pika
 import json
 import threading
 
 
 buffer = []
 lock = threading.Lock()
 
-print ('pika version: %s') % pika.__version__
+print('pika version: %s' % pika.__version__)
 
 
 connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
 
-main_channel     = connection.channel()   
-consumer_channel = connection.channel()   
-bind_channel     = connection.channel()   
+main_channel     = connection.channel()
+consumer_channel = connection.channel()
+bind_channel     = connection.channel()
 
 if pika.__version__=='0.9.5':
     main_channel.exchange_declare(exchange='com.micex.sten',       type='direct')
@@ -28,39 +28,39 @@
 queue         = main_channel.queue_declare(exclusive=True).method.queue
 queue_tickers = main_channel.queue_declare(exclusive=True).method.queue
 
-main_channel.queue_bind(exchange='com.micex.sten', queue=queue, routing_key='order.stop.create') 
+main_channel.queue_bind(exchange='com.micex.sten', queue=queue, routing_key='order.stop.create')
 
 
 
 def process_buffer():
-    if not lock.acquire(False): 
-        print 'locked!' 
+    if not lock.acquire(False):
+        print('locked!')
         return
     try:
         while len(buffer):
             body = buffer.pop(0)
-            
+
             ticker = None
             if 'ticker' in body['data']['params']['condition']: ticker = body['data']['params']['condition']['ticker']
             if not ticker: continue
-            
-            print 'got ticker %s, gonna bind it...' % ticker
-            bind_channel.queue_bind(exchange='com.micex.lasttrades', queue=queue_tickers, routing_key=str(ticker)) 
-            print 'ticker %s binded ok' % ticker
+
+            print('got ticker %s, gonna bind it...' % ticker)
+            bind_channel.queue_bind(exchange='com.micex.lasttrades', queue=queue_tickers, routing_key=str(ticker))
+            print('ticker %s binded ok' % ticker)
     finally:
         lock.release()
 
-        
+
 def callback(ch, method, properties, body):
     body = json.loads(body)['order.stop.create']
     buffer.append(body)
-    process_buffer()    
+    process_buffer()
+
 
-
 consumer_channel.basic_consume(callback,
                                queue=queue, no_ack=True)
 
-try:                      
-    consumer_channel.start_consuming()   
+try:
+    consumer_channel.start_consuming()
 finally:
     connection.close()

examples/consumer_simple.py

@@ -5,7 +5,7 @@
 import json
 
 
-print ('pika version: %s') % pika.__version__
+print(('pika version: %s') % pika.__version__)
 
 
 connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
@@ -28,7 +28,7 @@
 
 
 def hello():
-    print 'Hello world'
+    print('Hello world')
 
 connection.add_timeout(5, hello)
 
@@ -40,9 +40,9 @@ def callback(ch, method, properties, body):
     if 'ticker' in body['data']['params']['condition']: ticker = body['data']['params']['condition']['ticker']
     if not ticker: return
 
-    print 'got ticker %s, gonna bind it...' % ticker
+    print('got ticker %s, gonna bind it...' % ticker)
     bind_channel.queue_bind(exchange='com.micex.lasttrades', queue=queue_tickers, routing_key=str(ticker))
-    print 'ticker %s binded ok' % ticker
+    print('ticker %s binded ok' % ticker)
 
 
 import logging

examples/producer.py

@@ -5,7 +5,7 @@
 import json
 import random
 
-print ('pika version: %s') % pika.__version__
+print(('pika version: %s') % pika.__version__)
 
 connection   = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
 main_channel = connection.channel()  
@@ -36,6 +36,6 @@ def getticker(): return tickers.keys()[random.randrange(0,len(tickers)-1)]
                                body=json.dumps(msg),
                                properties=pika.BasicProperties(content_type='application/json')
                               )                          
-    print 'send ticker %s' %  ticker                         
+    print('send ticker %s' %  ticker)                         
 
 connection.close()

examples/publish.py

@@ -10,21 +10,21 @@
 channel.exchange_declare(exchange="test_exchange", exchange_type="direct",
                          passive=False, durable=True, auto_delete=False)
 
-print "Sending message to create a queue"
+print("Sending message to create a queue")
 channel.basic_publish('test_exchange', 'standard_key', 'queue:group',
                       pika.BasicProperties(content_type='text/plain',
                                            delivery_mode=1))
 
 connection.sleep(5)
 
-print "Sending text message to group"
+print("Sending text message to group")
 channel.basic_publish('test_exchange', 'group_key', 'Message to group_key',
                       pika.BasicProperties(content_type='text/plain',
                                            delivery_mode=1))
 
 connection.sleep(5)
 
-print "Sending text message"
+print("Sending text message")
 channel.basic_publish('test_exchange', 'standard_key', 'Message to standard_key',
                       pika.BasicProperties(content_type='text/plain',
                                            delivery_mode=1))

examples/send.py

@@ -10,7 +10,7 @@
 channel = connection.channel()
 
 def closeit():
-    print 'Close it'
+    print('Close it')
     connection.close()
 
 connection.add_timeout(5, closeit)