import pika

import json

credentials = pika.PlainCredentials('guest', 'guest',True)

parameters = pika.ConnectionParameters('44.221.204.9',

                                    33169,

                                    '/',

                                   credentials)

connection = pika.BlockingConnection(parameters)

channel = connection.channel()

def callback(ch, method, properties, body):

        data = body.decode()

        data = json.loads(body)

        print('data',data)

        return datas

channel.basic_consume(queue='ecritureOutTopic.ecritureOut-Group',on_message_callback=callback, auto_ack=False)

print('[*] En attente de messages. Pour quitter, appuyez sur CTRL+C')

channel.start_consuming()

connection.close()

--------------------

ERROR

Traceback (most recent call last):

  File "test.py", line 21, in

    connection = pika.BlockingConnection(parameters)

  File "/home/odoo/.local/lib/python3.8/site-packages/pika/adapters/blocking_connection.py", line 360, in __init__

    self._impl = self._create_connection(parameters, _impl_class)

  File "/home/odoo/.local/lib/python3.8/site-packages/pika/adapters/blocking_connection.py", line 451, in _create_connection

    raise self._reap_last_connection_workflow_error(error)

pika.exceptions.AMQPConnectionError