Python3 and rabbitmq

Im using rabbitmq in some of my python apps. Here is a small guide to get pyton3 to send and recive data from rabbitmq

 

I uses the code from

https://code.google.com/p/py-amqplib/

And read some guide from

http://blogs.digitar.com/jjww/2009/01/rabbits-and-warrens/ from 2009 !!!!

 

Get the pip you need to connect

sudo pip3 install amqp

 

 

My python code for sending and reciving

 

#!/usr/bin/env python
from amqplib import client_0_8 as amqp
import time
conn = amqp.Connection(host="192.168.122.208:5672 ", userid="guest",
password="guest", virtual_host="/", insist=False)
chan = conn.channel()
#Setup que
chan.queue_declare(queue="work", durable=True,
exclusive=False, auto_delete=False)
chan.exchange_declare(exchange="sorting_room", type="direct", durable=True,
auto_delete=False,)
chan.queue_bind(queue="work", exchange="sorting_room",
routing_key="domain")
#Send messages
send = amqp.Message("Test message!")
send.properties["delivery_mode"] = 2
chan.basic_publish(send,exchange="sorting_room",routing_key="domain")
#Get data runns and lissen for the loop
def recv_callback(msg):
print('Received: ' + msg.body + ' from channel #' + str(msg.channel.channel_id))
chan.basic_consume(queue='work', no_ack=True, callback=recv_callback, consumer_tag="testtag")
while True:
chan.wait()
chan.basic_cancel("testtag")

Leave a Reply

%d bloggers like this: