New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

AmazonMQ socket is closed continously #5001

Open
jcampbell05 opened this Issue Aug 22, 2018 · 5 comments

Comments

Projects
None yet
4 participants
@jcampbell05
Copy link

jcampbell05 commented Aug 22, 2018

Checklist

  • I have included the output of celery -A proj report in the issue.
    (if you are not able to do this, then at least specify the Celery
    version affected).
  • I have verified that the issue exists against the master branch of Celery.

Version 4.2, Python 2.7.14

Steps to reproduce

Spin up a AmaoznMQ server and try to connect to it.

Expected behavior

Celery should be able to connect to amazonMQ over AMQP

Actual behavior

See that celery spits out socket closed continously.

@clokep

This comment has been minimized.

Copy link
Contributor

clokep commented Aug 22, 2018

I think Amazon MQ only supports AMQP 1.0 (since it is based on ActiveMQ under the hood) (this Migrating from RabbitMQ to Amazon MQ article seems to mention AMQP 1.0 specifically many times for Amazon MQ.

I don't think any of the kombu brokers support AMQP 1.0 at the moment.

@jcampbell05

This comment has been minimized.

Copy link

jcampbell05 commented Aug 22, 2018

@clokep do we know if there is an issue tracking AMQP 1.0 support? I've read in a previous issue that this was supposed to be the case in Celery 4.X so some clarity would be awesome :)

@clokep

This comment has been minimized.

Copy link
Contributor

clokep commented Aug 22, 2018

@jcampbell05 celery/kombu#548 and celery/kombu#723 are the vaguely related ones I know about.

@jcampbell05

This comment has been minimized.

Copy link

jcampbell05 commented Aug 23, 2018

So I've been able to find out the only transport method which Kombu supports which enables this is QPID, but that fails with this error when I run it:
Transport' object has no attribute 'use_async_interface'

@yardensachs

This comment has been minimized.

Copy link

yardensachs commented Oct 6, 2018

Are there any plans to support ActiveMQ / AmazonMQ?

@auvipy auvipy added this to the v5.0.0 milestone Oct 12, 2018

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment