amqp - Esper AMQPSource 未收到事件

Question

我正在尝试使用 AMQPSource 并且我收到了下面描述的错误，并且导入在 EPL 模块中也不起作用。事先，我测试了将完整的包名添加到 DistanceEvent （events.DistanceEvent 并且不起作用）。

要发送消息，我正在使用带有下一个有效负载的发布 Rabbitmq webadmin queue 选项：{"distance":33}

有人可以帮我吗？

Answer 1

“IO 错误反序列化对象”是您看不到数据的原因。“AMQPToObjectCollectorSerializable”期望 AMQP 消息携带有效的 JVM 序列化对象，但是“无效标头”意味着 JVM 无法读取消息内容。检查发件人，确保它生成带有 JVM 序列化对象的 AMQP 消息，或者可以使用可以理解您的消息的反序列化器替换“AMQPToObjectCollectorSerializable”。如果您不确定它是如何反序列化的，可以在 Github 中找到“AMQPToObjectCollectorSerializable”的代码。