-
Notifications
You must be signed in to change notification settings - Fork 0
/
test_receiver.py
36 lines (26 loc) · 1.09 KB
/
test_receiver.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
import json
import os
import pika
import logging
# connection = pika.BlockingConnection(pika.ConnectionParameters(host=os.getenv('RABBIT_HOST')))
connection = pika.BlockingConnection(
pika.ConnectionParameters(host='rabbitmq'))
channel = connection.channel()
channel.queue_declare(queue='send_user_data_queue', durable=True)
channel.queue_declare(queue='receive_user_data_queue', durable=True)
logging.basicConfig(level=logging.INFO)
logging.log(logging.INFO, 'Waiting for messages')
def callback_game_data(ch, method, properties, body):
print(body)
body = body.decode()
logging.log(logging.ERROR, f"Received {body}")
print(body)
def callback_receive(ch, method, properties, body):
body = body.decode()
logging.log(logging.INFO, f"Received in receive {body}")
channel.basic_qos(prefetch_count=1)
channel.basic_consume(queue='send_user_data_queue',
on_message_callback=callback_game_data, auto_ack=True)
channel.basic_consume(queue='receive_user_data_queue',
on_message_callback=callback_receive, auto_ack=True)
channel.start_consuming()