I was doing telnet on 8990. --telnet 127.0.0.1 8990 Trying 127.0.0.1... Connected to localhost. Escape character is '^]'. Connection closed by foreign host.
----------------- I tried with making the ports as same in the broker url and acceptor. Port used was 5672 In both the scenarios, the server logs was showing 2023-12-14 15:33:14.362 DEBUG 12156 --- [ost-1787830293)] o.a.a.a.c.r.s.i.RemotingServiceImpl : RemotingServiceImpl::removing connection ID 43b1acbd And in the python client, it threw the following after 10 seconds Traceback (most recent call last): File "please_work.py", line 8, in <module> connection = pika.BlockingConnection(pika.URLParameters(broker_url)) File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/pika/adapters/blocking_connection.py", line 360, in __init__ self._impl = self._create_connection(parameters, _impl_class) File "/Library/Frameworks/Python.framework/Versions/3.7/lib/python3.7/site-packages/pika/adapters/blocking_connection.py", line 451, in _create_connection raise self._reap_last_connection_workflow_error(error) pika.adapters.utils.connection_workflow.AMQPConnectorStackTimeout: Timeout during AMQP handshake'127.0.0.1'/(<AddressFamily.AF_INET: 2>, <SocketKind.SOCK_STREAM: 1>, 6, '', ('127.0.0.1', 5672)); ssl=False The following is the python code being used import pika # Connection parameters broker_url = 'amqp://127.0.0.1:5672' queue_name = 'TEST' # Establish a connection to the broker connection = pika.BlockingConnection(pika.URLParameters(broker_url)) channel = connection.channel() # Declare a queue channel.queue_declare(queue=queue_name) # Send a message to the queue message_body = 'Hello from Python!' channel.basic_publish(exchange='', routing_key=queue_name, body=message_body) print(f" [x] Sent '{message_body}'")