Tag: azure-eventhub

IllegalStateException: Cannot Subscrie.Processor is already terminated

amqp azure-eventhub illegalstateexception java

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

Is there a way to get the headers data of events (EventHub) using @EventHubTrigger of Azure Functions in Java?

azure azure-eventhub azure-functions azure-java-tools java

I have an Azure Function implemented with azure-functions-java-library that receives events from one EventHub and I’m using @EventHubTrigger, the problem is that I need the header data from an event but I don’t see any way to get this, I have already read the docs and nothing. The reason I need this is because from the EventHub I’am receiving events