search

crabhi / celery-java

Java implementation of Celery client and worker
MIT License
97 stars 27 forks source link

Support SQS broker #7

Open sazlin opened 6 years ago

sazlin commented 6 years ago

Great work on this! Here's an issue to track adding SQS support, which I'd need to start experimenting with this at my company.

crabhi commented 6 years ago

Thanks for your interest @sazlin!

I'm working on version 1.1 (current master branch) that is refactored to make it possible to have multiple brokers/backends. Plus it should support initialization of the broker/backend from the URIs as the Python library does.

This version should land early in January. When this is done, it should be easier to provide a patch for SQS broker (implement the currently undocumented Broker and Message interfaces).

Either you can provide the SQS broker by yourself - I'll be here to guide you where I can - or I could provide it under a consulting agreement. If interested, feel free to contact me at filip@sedlakovi.org

crabhi commented 6 years ago

So now that v1.1 is out, check out you would start by implementing the BrokerFactory and register it as a Java service - in META-INF/services. I've added documentation to the SPI classes.