amqpespereplnesper

Esper AMQPSource not receiving events

I'm trying to use the AMQPSource and I'm getting the error describe below, also imports are not working in EPL module. In advance, I test adding full package name to DistanceEvent (events.DistanceEvent and does not work).

To sending a message i'm using the publish Rabbitmq webadmin queue option with the next payload: {"distance":33}

Could anyone help me?

Error

EPL Module

Deploying EPL Module

Event definition

Dataflow instance

Sender

Solution

  • The "IO-error deserializing object" is the reason you are not seeing data. The "AMQPToObjectCollectorSerializable" expects the AMQP message to carry a valid JVM-serialized object however the "invalid header" means that the message content cannot be read by the JVM. Check the sender making sure it produces a AMQP message with a JVM-serialized object or may use replace "AMQPToObjectCollectorSerializable" with a deserializer that can understand your message. The code for "AMQPToObjectCollectorSerializable" can be found in Github if your are not sure how it deserializes.