x/box-o-sand
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Pulling out channel setup into common bits

Browse Source 
as was suggested in book.
This commit is contained in:
Dan Buch 2012-11-14 18:03:45 -05:00
parent 1120412e45
commit 26ec865dd7
4 changed files with 22 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

0
sylvilagus/python/sylvilagus/chapter02/__init__.py Normal file
View File

16
sylvilagus/python/sylvilagus/chapter02/hello_world.py Normal file
View File

@ -0,0 +1,16 @@
import pika
def get_channel():
credentials = pika.PlainCredentials('guest', 'guest')
conn_params = pika.ConnectionParameters('localhost',
credentials=credentials)
channel = pika.BlockingConnection(conn_params).channel()
channel.exchange_declare(exchange='hello-exchange',
type='direct',
passive=False,
durable=True,
auto_delete=False)
return channel

13
sylvilagus/python/sylvilagus/chapter02/hello_world_consumer.py
View File

@ -4,6 +4,8 @@ import sys
import pika
from sylvilagus.chapter02 import hello_world
def msg_consumer(channel, method, header, body):
channel.basic_ack(delivery_tag=method.delivery_tag)
@ -16,16 +18,7 @@ def msg_consumer(channel, method, header, body):
def main():
credentials = pika.PlainCredentials('guest', 'guest')
conn_params = pika.ConnectionParameters('localhost',
credentials=credentials)
conn_broker = pika.BlockingConnection(conn_params)
channel = conn_broker.channel()
channel.exchange_declare(exchange='hello-exchange',
type='direct',
passive=False,
durable=True,
auto_delete=False)
channel = hello_world.get_channel()
channel.queue_declare(queue='hello-queue')
channel.queue_bind(queue='hello-queue',

13
sylvilagus/python/sylvilagus/chapter02/hello_world_producer.py
View File

@ -4,18 +4,11 @@ import sys
import pika
from sylvilagus.chapter02 import hello_world
def main(args=sys.argv[:]):
credentials = pika.PlainCredentials('guest', 'guest')
conn_params = pika.ConnectionParameters('localhost',
credentials=credentials)
conn_broker = pika.BlockingConnection(conn_params)
channel = conn_broker.channel()
channel.exchange_declare(exchange='hello-exchange',
type='direct',
passive=False,
durable=True,
auto_delete=False)
channel = hello_world.get_channel()
msg = args[1]
msg_props = pika.BasicProperties()