From 19c8f88bf97e8ed39eb51cd7997fe2748ac592df Mon Sep 17 00:00:00 2001 From: zhaohaihzb Date: Sat, 31 Jan 2026 08:02:53 +0800 Subject: [PATCH] pushConsumer add ssl --- .../rocketmq/client/annotation/RocketMQMessageListener.java | 5 +++++ .../client/autoconfigure/ListenerContainerConfiguration.java | 1 + 2 files changed, 6 insertions(+) diff --git a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/RocketMQMessageListener.java b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/RocketMQMessageListener.java index 67796a9d..6f0f836d 100644 --- a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/RocketMQMessageListener.java +++ b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/RocketMQMessageListener.java @@ -58,6 +58,11 @@ */ String tag() default TAG_PLACEHOLDER; + /** + * Enable or disable the use of Secure Sockets Layer (SSL) for network transport. + */ + boolean sslEnabled() default true; + /** * The type of filter expression */ diff --git a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java index 450d846e..1975dccf 100644 --- a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java +++ b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java @@ -108,6 +108,7 @@ private DefaultListenerContainer createRocketMQListenerContainer(String name, Ob container.setConsumptionThreadCount(annotation.consumptionThreadCount()); container.setMaxCacheMessageSizeInBytes(annotation.maxCacheMessageSizeInBytes()); container.setType(annotation.filterExpressionType()); + container.setSslEnabled(annotation.sslEnabled()); return container; }