(rocketmq-spring) branch master updated: PushConsumer add ssl switch (#765)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new ce5f729  PushConsumer add ssl switch (#765)
ce5f729 is described below

commit ce5f729705154fe5d12e48ddcd529521725592ee
Author: zhaohai <33314633+zhaohai...@users.noreply.github.com>
AuthorDate: Tue Feb 10 10:14:17 2026 +0800

    PushConsumer add ssl switch (#765)
---
 .../apache/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 67796a9..6f0f836 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 @@ public @interface RocketMQMessageListener {
      */
     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 450d846..1975dcc 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 @@ public class ListenerContainerConfiguration implements 
ApplicationContextAware {
         
container.setConsumptionThreadCount(annotation.consumptionThreadCount());
         
container.setMaxCacheMessageSizeInBytes(annotation.maxCacheMessageSizeInBytes());
         container.setType(annotation.filterExpressionType());
+        container.setSslEnabled(annotation.sslEnabled());
         return container;
     }