Слушатель RabbitMQ не может преобразовать сообщение - PullRequest
0 голосов
/ 29 ноября 2018

У меня есть производитель сообщений, который отправляет сообщение на кролика, используя RabbitTemplate.У него есть конвертер сообщений: Jackson2JsonMessageConverter.

Я пытаюсь получить сообщение от слушателя так:

@RabbitListener(queues = "kolejka")
public void listen(String message) {
    try {
        log.info("Received ---------------------------------------------------");
        log.info(message);
    } catch (Exception e) {
        log.debug("Error thrown while listening + " + e.getMessage());
    }

}

К сожалению, сообщение - это массив чисел от 45 до 130, это похоже наAscii, так что у моего слушателя плохая кодировка.Я попытался изменить метод прослушивателя на прослушивание (Сообщение сообщения), а затем преобразовать сообщение в объект, например:

public void listen(Message messsage) {
    Transfer transfer = (Transfer) jackson2JsonMessageConverter.fromMessage(messsage);

, но он выдает предупреждение о том, что сообщение не было закодировано надлежащим образом и было брошено в очередь недоставленных сообщений.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...