crabhi / celery-java

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

New feature: message with priority #13

Open StonesGitHub opened 6 years ago

StonesGitHub commented 6 years ago

I found that if the queue in rabbitmq is a queue with priority, it will report error: x-max-priority is none, but the queue is not To support sending message with priority, a few changes have been made to enable priority queue

StonesGitHub commented 6 years ago

Hi @crabhi , I have made some changes accordingly, as well as supplying a test case(I have tested it on my local machine). Pls review the code. ^_^

todd-cook commented 5 years ago

Curious what the status of this is @crabhi