crans/crans_ticket
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

paramétrise la QUEUE côté serveur

Browse source
This commit is contained in:
Daniel STAN 2015-02-23 20:41:28 +01:00
parent b0f3090cfe
commit e0a0fb60c8
2 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
config.py.example
View file

@ -7,3 +7,5 @@ PARAMS = pika.ConnectionParameters(host='rabbitmq.crans.org',
port=5671, credentials=CREDS, ssl=True) port=5671, credentials=CREDS, ssl=True)
DEVICE = "/dev/ttyAMA0" #Ou USB0 sur oie DEVICE = "/dev/ttyAMA0" #Ou USB0 sur oie
QUEUE = 'CransTicket' # ou 'CransTicketDebug' en test

4
daemon.py
View file

@ -12,12 +12,12 @@ import config
def run(): def run():
conn = pika.BlockingConnection(config.PARAMS) conn = pika.BlockingConnection(config.PARAMS)
ch = conn.channel() ch = conn.channel()
ch.queue_declare(queue='CransTicketDebug') ch.queue_declare(queue=config.QUEUE)
def callback(ch, method, properties, body): def callback(ch, method, properties, body):
print (" [x] Received %r" % (body,)) print (" [x] Received %r" % (body,))
dump.print_liste(json.loads(body)) dump.print_liste(json.loads(body))
ch.basic_consume(callback, queue='CransTicketDebug', no_ack=True) ch.basic_consume(callback, queue=config.QUEUE, no_ack=True)
ch.start_consuming() ch.start_consuming()
conn.close() conn.close()
# fork en arrière plan + pidfile # fork en arrière plan + pidfile