Esper AMQPSource не получает события
Я пытаюсь использовать AMQPSource и получаю сообщение об ошибке, описанное ниже, также импорт не работает в модуле EPL. Заранее я тестирую добавление полного имени пакета в DistanceEvent (events.DistanceEvent и не работает).
Для отправки сообщения я использую опцию публикации очереди Rabbitmq webadmin со следующей полезной нагрузкой: {"distance":33}
Кто-нибудь может мне помочь?
1 ответ
"Объект десериализации ошибок ввода-вывода" - это причина, по которой вы не видите данные. "AMQPToObjectCollectorSerializable" ожидает, что сообщение AMQP будет содержать действительный сериализованный объект JVM, однако "неверный заголовок" означает, что содержимое сообщения не может быть прочитано JVM. Проверьте отправителя, убедившись, что он генерирует сообщение AMQP с сериализованным объектом JVM или может использовать замену "AMQPToObjectCollectorSerializable" десериализатором, который может понять ваше сообщение. Код для "AMQPToObjectCollectorSerializable" можно найти в Github, если вы не уверены, как он десериализуется.