notebook.community

Edit and run 





In [ ]:



    


import rabbitpy



    











In [ ]:



    


message = rabbitpy.get(queue_name='mqtt-messages')
if message:
    message.pprint(True)
    message.ack()
else:
    print('No message in queue')

Content source: gmr/RabbitMQ-in-Depth

Similar notebooks:

notebook.community | gallery | about