Cant convert incoming message from RabbitMQ queue

Message converter in my rabbitmqconfig file:

@Bean
    public Jackson2JsonMessageConverter jsonMessageConverter() {
        ObjectMapper objectMapper = new ObjectMapper();
        return new Jackson2JsonMessageConverter(objectMapper);
    }

@Bean
    public Jackson2JsonMessageConverter jsonMessageConverter() {
        ObjectMapper objectMapper = new ObjectMapper();
        return new Jackson2JsonMessageConverter(objectMapper);
    }

Consumer class:

@RabbitListener(queues = "${broker.queue.email.name}")
    public void listenerEmailQueue(Message<EmailNotificationDto> emailRequest) {

        System.out.println(emailRequest.getPayload().getItem());
    }

@RabbitListener(queues = "${broker.queue.email.name}")
    public void listenerEmailQueue(Message<EmailNotificationDto> emailRequest) {

        System.out.println(emailRequest.getPayload().getItem());
    }

And i get the following error whenever a message is consumed:
org.springframework.amqp.rabbit.support.ListenerExecutionFailedException: Listener method could not be invoked with the incoming message

No converter found from actual payload type 'byte[]' to expected payload type

Anyone able to help please?

JC|HCL

Java Community | Help. Code. Learn.•5mo ago•

162 replies

Victor

Cant convert incoming message from RabbitMQ queue

Message converter in my rabbitmqconfig file:

@Bean
    public Jackson2JsonMessageConverter jsonMessageConverter() {
        ObjectMapper objectMapper = new ObjectMapper();
        return new Jackson2JsonMessageConverter(objectMapper);
    }

@Bean
    public Jackson2JsonMessageConverter jsonMessageConverter() {
        ObjectMapper objectMapper = new ObjectMapper();
        return new Jackson2JsonMessageConverter(objectMapper);
    }

Consumer class:

@RabbitListener(queues = "${broker.queue.email.name}")
    public void listenerEmailQueue(Message<EmailNotificationDto> emailRequest) {

        System.out.println(emailRequest.getPayload().getItem());
    }

@RabbitListener(queues = "${broker.queue.email.name}")
    public void listenerEmailQueue(Message<EmailNotificationDto> emailRequest) {

        System.out.println(emailRequest.getPayload().getItem());
    }

Cant convert incoming message from RabbitMQ queue

Similar Threads

Cant convert incoming message from RabbitMQ queue

Similar Threads

Similar Threads

Similar Threads