ClassCastException when I consume a message about azure-event-hubs-java HOT 6 CLOSED

HI @atdi which library are you using for sending events?

from azure-event-hubs-java.

Not when I send events is the problem and when I consume them.
I used those dependencies:

com.microsoft.azure
azure-eventhubs
0.10.0


com.microsoft.azure
azure-eventhubs-eph
0.10.0

from azure-event-hubs-java.

We ask about the sender because this looks like compatibility issues that we have seen before, where the sender formats the body of the message in an AMQP type that our receiver is not prepared to handle. Some senders can prepare a message in a variety of ways and the easiest way to get this working may be to change an option on the sender.

from azure-event-hubs-java.

@atdi - did you send messages to eventhub with body section as AmqpValue ? Current version of our client has a bug - where it is not compatible with AmqpValue & AmqpSequence. with #66 - it is fixed. pls. see if you can try it and provide any feedback.

from azure-event-hubs-java.

@atdi - we truly appreciate for filing this interoperability issue. This helped us to 1 up our quality.
This bug has been fixed and is pulled into the current release #82. We are in the process of releasing 0.13.0 - which will include the fix.

from azure-event-hubs-java.

I am seeing similar behavior. I am using the QPID Proton to send. What is the proper way to consume an AMQP message from Java?

I can see amqpBody is not null in my EventData instance, but the call to getBytes() returns null.

My gradle has the following

'com.microsoft.azure:azure-eventhubs-eph:0.13.0',
'com.microsoft.azure:azure-eventhubs:0.13.0',

from azure-event-hubs-java.