Skip to content

Commit ce5f729

Browse files
authored
PushConsumer add ssl switch (#765)
1 parent c9fc2e3 commit ce5f729

2 files changed

Lines changed: 6 additions & 0 deletions

File tree

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/RocketMQMessageListener.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,11 @@
5858
*/
5959
String tag() default TAG_PLACEHOLDER;
6060

61+
/**
62+
* Enable or disable the use of Secure Sockets Layer (SSL) for network transport.
63+
*/
64+
boolean sslEnabled() default true;
65+
6166
/**
6267
* The type of filter expression
6368
*/

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/ListenerContainerConfiguration.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -108,6 +108,7 @@ private DefaultListenerContainer createRocketMQListenerContainer(String name, Ob
108108
container.setConsumptionThreadCount(annotation.consumptionThreadCount());
109109
container.setMaxCacheMessageSizeInBytes(annotation.maxCacheMessageSizeInBytes());
110110
container.setType(annotation.filterExpressionType());
111+
container.setSslEnabled(annotation.sslEnabled());
111112
return container;
112113
}
113114

0 commit comments

Comments
 (0)