From 6830b43c1867769609046655cfb6892db111ca6e Mon Sep 17 00:00:00 2001 From: lihongjie0209 Date: Fri, 29 Mar 2024 22:42:32 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84rabbitmq=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../coal/rabbitmq/RabbitMQConfiguration.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/src/main/java/cn/lihongjie/coal/rabbitmq/RabbitMQConfiguration.java b/src/main/java/cn/lihongjie/coal/rabbitmq/RabbitMQConfiguration.java index 3fad42a1..7e39839f 100644 --- a/src/main/java/cn/lihongjie/coal/rabbitmq/RabbitMQConfiguration.java +++ b/src/main/java/cn/lihongjie/coal/rabbitmq/RabbitMQConfiguration.java @@ -1,8 +1,13 @@ package cn.lihongjie.coal.rabbitmq; +import com.fasterxml.jackson.databind.ObjectMapper; + import org.springframework.amqp.core.*; import org.springframework.amqp.core.Queue; import org.springframework.amqp.rabbit.annotation.EnableRabbit; +import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.autoconfigure.amqp.RabbitTemplateCustomizer; import org.springframework.boot.convert.DurationStyle; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @@ -27,6 +32,14 @@ public class RabbitMQConfiguration { public static final Long[] DELAY_QUEUES_TIME = Arrays.stream(DELAY_QUEUES).map(x -> DurationStyle.detectAndParse(x).toMillis()).toArray(Long[]::new); + @Autowired private ObjectMapper objectMapper; + + @Bean + RabbitTemplateCustomizer rabbitTemplateCustomizer() { + return template -> { + template.setMessageConverter(new Jackson2JsonMessageConverter(objectMapper)); + }; + } @Bean