FilesExpand file tree

 master

/

receive.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

executable file

·

20 lines (13 loc) · 469 Bytes

 master

/

receive.py

Copy path

Top

File metadata and controls

• Code
• Blame

executable file

·

20 lines (13 loc) · 469 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

#!/usr/bin/env python

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(

host='localhost'))

channel = connection.channel()

channel.queue_declare(queue='hello')

print ' [*] Waiting for messages. To exit press CTRL+C'

def callback(ch, method, properties, body):

print " [x] Received %r" % (body,)

channel.basic_consume(callback,

queue='hello',

no_ack=True)

channel.start_consuming()