0x2620/cablegates
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

app is called pandora now

Browse source
This commit is contained in:
j 2010-06-24 15:18:33 +02:00
commit b05f8fdb83
4 changed files with 28 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

10
pandora/backend/encoder.py
View file

@ -8,17 +8,17 @@ import models
def send_encoder_message(msg):
conn = DjangoBrokerConnection()
publisher = Publisher(connection=conn, exchange="oxdb-encoder",
routing_key="oxdb-encoder")
publisher = Publisher(connection=conn, exchange="pandora-encoder",
routing_key="pandora-encoder")
publisher.send(msg)
publisher.close()
def run():
conn = DjangoBrokerConnection()
consumer = Consumer(connection=conn, queue="oxdb-encoder",
exchange="oxdb-encoder",
routing_key="oxdb-encoder")
consumer = Consumer(connection=conn, queue="pandora-encoder",
exchange="pandora-encoder",
routing_key="pandora-encoder")
def handle_background_tasks_callback(data, message):
print("Got encoder message")
print data