Ошибка типа аргумента с приемником Spring AMQP

Question

Приложение Spring AMQP регистрирует следующее исключение при инициализации:

org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Failed to invoke target method 'receiveMessage' with argument type = [class [B], value = [{[B@660cff44}]

Из моего поиска я понимаю, что это происходит из-за несовместимости классов с типом сообщения?Однако я не могу увидеть, где это.

Ниже приведены соответствующие сегменты кода:

@Bean
public MessageConverter jsonMessageConverter(){
    return new Jackson2JsonMessageConverter();
}

@Bean
Queue queue() {
    return new Queue(config.getAMQPResultsQueue(), false);
}

@Bean
TopicExchange exchange() {
    return new TopicExchange(config.getAMQPResultsExchange());
}

@Bean
Binding binding(Queue queue, TopicExchange exchange) {
    return BindingBuilder.bind(queue).to(exchange).with("#");
}

@Bean
SimpleMessageListenerContainer container(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setQueueNames(config.getAMQPResultsQueue());
    container.setMessageListener(listenerAdapter);
    container.setMessageConverter(jsonMessageConverter());
    return container;
}

@Bean
MessageListenerAdapter listenerAdapter(Receiver receiver) {
    return new MessageListenerAdapter(receiver, "receiveMessage");
}

и

@Component
public class Receiver {
    public void receiveMessage(String message) {
        System.out.println("Received <" + message + ">");
    }
}

Я попытался установитькласс сообщения в Byte [], но результат тот же.Я уверен, что упускаю что-то простое - просто не уверен, что это такое!

Answer 1

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

В противном случае оно вернет byte[].

byte[]также не будет преобразован в Byte[].Установите заголовок или используйте byte[].