celery-java

celery-java copied to clipboard

Project Maintenance

1

Is this project still being maintained?

andystroz

I calling python task form java, and the java app need get task result. but i see each message is unack in rabbitmq. and call about 5times, rabbitmq will disconnet...

wjjboy

I am trying to code the example in language Kotlin: ```kotlin /* * This Kotlin source file was generated by the Gradle 'init' task. */ package poc_kotlin_celery import com.geneea.celery.* fun...

mdtrooper

Task id can not be retrieved by the client side

1

Given the client and worker of celery might be deployed on different machines, to let the client side record the task id is very useful when locating problems. Currently, the...

StonesGitHub

how to use redis for broker?

2

It seems that celery-java do not support the redis broker this is my code: ` Celery client = Celery.builder() .brokerUri("redis://:M2EzYmNiYzc3Y2IyZWFiNzRhMjkxOGU4ODJiY2YyOTJhOWVmMTQ5YjEwOGZkODFl@10.19.0.11:6379/3") // .backendUri("rpc://:M2EzYmNiYzc3Y2IyZWFiNzRhMjkxOGU4ODJiY2YyOTJhOWVmMTQ5YjEwOGZkODFl@10.19.0.11:6379/3") .build(); try { System.out.println(client.submit("tasks.add", new Object[]{1, 2}).get()); //...

longpan

TaskLoader.vm and TaskProxy.vm error

1

celery-java 在运行task时，会加载task类信息,启用TaskLoader.vm和TaskProxy.vm 在annotations下生成模板，而在加载类信息是会有一个bug,当我的task类是在java下，那么他默认是没有package信息的，所以会导致生成错误的模板 com.geneea.celery.annotationprocessor.TaskProcessor.process 有如下代码： PackageElement packageElement = (PackageElement) taskClassElem.getEnclosingElement(); Name packageName = packageElement.getQualifiedName(); writeProxy(taskClassElem, methods, packageName); writeLoader(taskClassElem, packageName); 这里的packageName 为null ,导致模板生成错误

qiuxiaode

When creating the queue I get the error: ``` java.io.IOException at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:129) at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:125) at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:147) at com.rabbitmq.client.impl.ChannelN.queueDeclare(ChannelN.java:968) at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.queueDeclare(AutorecoveringChannel.java:333) at com.geneea.celery.CeleryWorker.create(CeleryWorker.java:187) at com.geneea.celery.CeleryWorker.main(CeleryWorker.java:216) at com.fabrikado.materialise_wrapper.MaterialiseApp.main(MaterialiseApp.java:60) Caused by: com.rabbitmq.client.ShutdownSignalException: channel...

fsulser

Potential conflict in Velocity properties

1

The file `velocity.properties` should be namespaced.

crabhi

Too many opened connections

2

Hello, I'm using the library with a webservice but everytime I publish a message, a connection is opened and never closed. The thing is that after a few hours the...

diego-iturriaga

New feature: message with priority

2

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...

StonesGitHub