I created a new eventhub and trying to publish messages to eventHubA. When I am trying to send messages to eventhub , I get the following error: java.lang.IllegalStateException: namespace[xxxxx] entityPath[xxxxx]: Cannot subscribe. Processor is already terminated at com.azure.core.amqp.implementation.AmqpChannelProcessor.subscribe(AmqpChannelProcessor.java:217) Below is the code snippet i am using: I have defined the eventhubProducerClient as a Bean. Below is my gradle dependencies Answer
Tag: amqp
Java RabbitMQ: can’t map message to corresponding class
I have two different java spring projects that communicate through rabbitmq. I’m trying to send a java object but I get this error message: I’m aware that the problem is in the classpath that should be the same in both producer and consumer, but since each project has a different name I can’t make the classpath the same even though
Connect to an azure iot hub from inside a kubernetes cluster via amqp over websockets
we are trying to communicate to an azure iothub via amqp over websocket from a java docker container inside an azure kubernetes cluster. Sadly it seems, that the container cant establish a connection …
java.lang.IllegalArgumentException when publishing a message with RabbitTemplate
I try to publish a message on a Queue with RabbitTemplate (using Spring Boot) and I got this message. I already tried to search for a solution. Maybe this part of code can help I appreciate any collaboration. Answer The problem is that your class SimpleMessage does not implement Serializable. RabbitTemplate.convertAndSend uses SimpleMessageConveter to convert your message into an amqp