Failed to declare queue by RabbitMQ for Activiti Cloud Connector

cancel
Showing results for 
Search instead for 
Did you mean: 
saahilbhutwala
Member II

Failed to declare queue by RabbitMQ for Activiti Cloud Connector

Hello, I am a Java developer working on creating a bpmn engine using Activiti deployed on a GKE Cluster. Currently, I have the cloud application set up and a runtime bundle with a bpmn process as well. With my cloud connector, I want it to interact with a job processing service and relay back the status once the job is finished. But after setting up everything I am encountering this error related to RabbitMQ queues that I cannot debug or am able to solve anywhere. I am new to rabbitMQ so any help would be highly appreciated please. Here is the error log :

 

o.s.a.r.listener.BlockingQueueConsumer : Failed to declare queue: runtimeCmdResults.anonymous.pTfeJVxdS-S2iG0GI6Oe3g
    o.s.a.r.listener.BlockingQueueConsumer : Queue declaration failed; retries left=3
    org.springframework.amqp.rabbit.listener.BlockingQueueConsumer$DeclarationException: Failed to declare queue(s):[runtimeCmdResults.anonymous.pTfeJVxdS-S2iG0GI6Oe3g] 
at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.attemptPassiveDeclarations(BlockingQueueConsumer.java:710) ~[spring-rabbit-2.1.3.RELEASE.jar!/:2.1.3.RELEASE] at 
org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.passiveDeclarations(BlockingQueueConsumer.java:594) ~[spring-rabbit-2.1.3.RELEASE.jar!/:2.1.3.RELEASE] at 
org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:581) ~[spring-rabbit-2.1.3.RELEASE.jar!/:2.1.3.RELEASE] at 
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.initialize(SimpleMessageListenerContainer.java:1196) 
~[spring-rabbit-2.1.3.RELEASE.jar!/:2.1.3.RELEASE] at 
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1041) ~[spring-rabbit-2.1.3.RELEASE.jar!/:2.1.3.RELEASE] at 
java.base/java.lang.Thread.run(Thread.java:834) ~[na:na] Caused by: java.io.IOException: null at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:126) ~[amqp-client-5.4.3.jar!/:5.4.3] at 
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:122) ~[amqp-client-5.4.3.jar!/:5.4.3] at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:144) ~[amqp-client-5.4.3.jar!/:5.4.3] at 
com.rabbitmq.client.impl.ChannelN.queueDeclarePassive(ChannelN.java:1006) ~[amqp-client-5.4.3.jar!/:5.4.3] at com.rabbitmq.client.impl.ChannelN.queueDeclarePassive(ChannelN.java:52) ~[amqp-client-5.4.3.jar!/:5.4.3] at
jdk.internal.reflect.GeneratedMethodAccessor108.invoke(Unknown Source) ~[na:na] at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:na] at 
java.base/java.lang.reflect.Method.invoke(Method.java:566) ~[na:na] at
org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:1110) ~[spring-rabbit-2.1.3.RELEASE.jar!/:2.1.3.RELEASE] at 
com.sun.proxy.$Proxy137.queueDeclarePassive(Unknown Source) ~[na:na] at 
org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.attemptPassiveDeclarations(BlockingQueueConsumer.java:689) ~[spring-rabbit-2.1.3.RELEASE.jar!/:2.1.3.RELEASE] ... 5 common frames omitted Caused by: 
com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 
'runtimeCmdResults.anonymous.pTfeJVxdS-S2iG0GI6Oe3g' in vhost '/', class-id=50, method-id=10) at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:66) ~[amqp-client-5.4.3.jar!/:5.4.3] at 
com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36) ~[amqp-client-5.4.3.jar!/:5.4.3] at 
com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:494) ~[amqp-client-5.4.3.jar!/:5.4.3] at 
com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:288) ~[amqp-client-5.4.3.jar!/:5.4.3] at com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:138) ~
[amqp-client-5.4.3.jar!/:5.4.3] ... 13 common frames omitted Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: 
#method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'runtimeCmdResults.anonymous.pTfeJVxdS-S2iG0GI6Oe3g' in vhost '/', class-id=50, method-id=10) at 
com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:516) ~[amqp-client-5.4.3.jar!/:5.4.3] at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:346) ~[amqp-client-5.4.3.jar!/:5.4.3] at 
com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:178) ~[amqp-client-5.4.3.jar!/:5.4.3]

 

image.pngo.s.a.r.c.CachingConnectionFactory : Channel shutdown: connection error; protocol method: #method<connection.close>(reply-code=503, reply-text=COMMAND_INVALID - unknown exchange type 'x-delayed-message', class-id=40, method-id=10)
this error I believe is the root cause of everything.

Any help is highly appreciated.

Thanks.