Search code examples
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.