From beae97523fa562674f21fd3987b326369b11d49d Mon Sep 17 00:00:00 2001 From: weihu Date: Fri, 27 May 2022 10:16:02 +0800 Subject: [PATCH] add containerFactory --- .../starter/adapter/rabbitmq/example/MessageConsume.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-rabbitmq-example/src/main/java/cn/hippo4j/springboot/starter/adapter/rabbitmq/example/MessageConsume.java b/hippo4j-example/hippo4j-spring-boot-starter-adapter-rabbitmq-example/src/main/java/cn/hippo4j/springboot/starter/adapter/rabbitmq/example/MessageConsume.java index 0f4c936a..8a10a7a2 100644 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-rabbitmq-example/src/main/java/cn/hippo4j/springboot/starter/adapter/rabbitmq/example/MessageConsume.java +++ b/hippo4j-example/hippo4j-spring-boot-starter-adapter-rabbitmq-example/src/main/java/cn/hippo4j/springboot/starter/adapter/rabbitmq/example/MessageConsume.java @@ -34,7 +34,7 @@ import org.springframework.stereotype.Component; public class MessageConsume { @RabbitHandler - @RabbitListener(queuesToDeclare = @Queue(SimpleMQConstant.QUEUE_NAME)) + @RabbitListener(queuesToDeclare = @Queue(SimpleMQConstant.QUEUE_NAME), containerFactory = "defaultRabbitListenerContainerFactory") public void receiveObject(SendMessageDTO simple) throws JsonProcessingException { ObjectMapper objectMapper = new ObjectMapper(); String message = objectMapper.writeValueAsString(simple);