rabbitmq/rabbitmq-tutorials

Connection refused error while using cloudamqp as a message broker in Celery

harshgangwar opened this issue · 2 comments

I am using cloudamqp as a message broker of celery worker.

Connection Code:
app = Celery('tasks',
broker='amqp://<>:<>@<>/<>')

Error message after running this command- celery -A tasks worker --loglevel=info
Message:
[2019-04-26 12:50:33,074: ERROR/MainProcess] consumer: Cannot connect to amqp://xyz:**@xyz.xyz:5672/vhost: [Errno 111] Connection refused.
Trying again in 6.00 seconds...

I am not getting why it is happening.

Thank you for your time.

Team RabbitMQ uses GitHub issues for specific actionable items engineers can work on. GitHub issues are not used for questions, investigations, root cause analysis, discussions of potential issues, etc (as defined by this team).

We get at least a dozen of questions through various venues every single day, often light on details.
At that rate GitHub issues can very quickly turn into a something impossible to navigate and make sense of even for our team. Because GitHub is a tool our team uses heavily nearly every day, the signal/noise ratio of issues is something we care about a lot.

Please post this to rabbitmq-users.

Thank you.

There is a Network Troubleshooting guide and CloudAMQP have pretty great support (who has access to logs and other relevant information we don't have).