Esper AMQPSource 没有收到事件
Esper AMQPSource not receiving events
我正在尝试使用 AMQPSource，但出现了下面描述的错误，而且导入在 EPL 模块中不起作用。事先，我测试将完整的包名称添加到 DistanceEvent（events.DistanceEvent 并且不起作用）。
为了发送消息，我使用发布 Rabbitmq webadmin 队列选项和下一个负载：
{"distance":33}
谁能帮帮我？
"IO-error deserializing object" 是您看不到数据的原因。
"AMQPToObjectCollectorSerializable" 期望 AMQP 消息携带有效的 JVM 序列化对象，但是 "invalid header" 意味着 JVM 无法读取消息内容。检查发件人，确保它生成带有 JVM 序列化对象的 AMQP 消息，或者可以将 "AMQPToObjectCollectorSerializable" 替换为可以理解您的消息的反序列化程序。 "AMQPToObjectCollectorSerializable" 的代码可以在 Github 中找到，如果您不确定它是如何反序列化的。
我正在尝试使用 AMQPSource，但出现了下面描述的错误，而且导入在 EPL 模块中不起作用。事先，我测试将完整的包名称添加到 DistanceEvent（events.DistanceEvent 并且不起作用）。
为了发送消息，我使用发布 Rabbitmq webadmin 队列选项和下一个负载： {"distance":33}
谁能帮帮我？
"IO-error deserializing object" 是您看不到数据的原因。 "AMQPToObjectCollectorSerializable" 期望 AMQP 消息携带有效的 JVM 序列化对象，但是 "invalid header" 意味着 JVM 无法读取消息内容。检查发件人，确保它生成带有 JVM 序列化对象的 AMQP 消息，或者可以将 "AMQPToObjectCollectorSerializable" 替换为可以理解您的消息的反序列化程序。 "AMQPToObjectCollectorSerializable" 的代码可以在 Github 中找到，如果您不确定它是如何反序列化的。