Mar-20-2019, 06:28 AM
Hi,
I am using python3.5.3 and pika version 0.13.0
My code
<BlockingConnection impl=<SelectConnection OPEN socket=('127.0.0.1', 40068)->('127.0.0.1', 5672) params=<ConnectionParameters host=
localhost port=5672 virtual_host=/ ssl=False>>>
1
It did't call basic_handler definition . I am not getting the message "I am reached here" in baic_handler definition
I cannot understand what i did wrong why it is not calling the function basic_handler
I am using python3.5.3 and pika version 0.13.0
My code
def functions(host):
global LOGGER
global RABBITMQ_USER
global RABBITMQ_PASSWORD
while True:
try:
credentials = pika.PlainCredentials(RABBITMQ_USER, RABBITMQ_PASSWORD)
connection = pika.BlockingConnection(pika.ConnectionParameters(
host=host,
credentials=credentials))
print(connection)
channel = connection.channel()
channel.basic_qos(prefetch_size=0, prefetch_count=0, all_channels=True)
channel.basic_consume(basic_handler,
queue='grinshares',
no_ack=False)
channel.basic_consume(basic_handler,
queue='poolshares',
no_ack=False)
print("1")
channel.start_consuming()
print("2")
except Exception as e:
LOGGER.error("Something went wrong: {}\n{}".format(e, traceback.format_exc().splitlines()))
sys.stdout.flush()
time.sleep(10)basic_handler definitiondef basic_handler(ch, method, properties, body):
global LOGGER
global SHARES
global HEIGHT
print("I am reached here")
/// some code
sys.stdout.flush()While i run i am getting . I mention some print statements in my code<BlockingConnection impl=<SelectConnection OPEN socket=('127.0.0.1', 40068)->('127.0.0.1', 5672) params=<ConnectionParameters host=
localhost port=5672 virtual_host=/ ssl=False>>>
1
It did't call basic_handler definition . I am not getting the message "I am reached here" in baic_handler definition
I cannot understand what i did wrong why it is not calling the function basic_handler
