File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
remoting/src/main/java/org/apache/rocketmq/remoting/netty Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -129,7 +129,7 @@ public Thread newThread(Runnable r) {
129
129
}
130
130
});
131
131
132
- if (nettyClientConfig .isUseTLS ()) {
132
+ if (nettyClientConfig .isUseTLS () || TlsSystemConfig . tlsEnable ) {
133
133
try {
134
134
sslContext = TlsHelper .buildSslContext (true );
135
135
log .info ("SSL enabled for client" );
@@ -170,7 +170,7 @@ public Thread newThread(Runnable r) {
170
170
@ Override
171
171
public void initChannel (SocketChannel ch ) throws Exception {
172
172
ChannelPipeline pipeline = ch .pipeline ();
173
- if (nettyClientConfig .isUseTLS ()) {
173
+ if (nettyClientConfig .isUseTLS () || TlsSystemConfig . tlsEnable ) {
174
174
if (null != sslContext ) {
175
175
pipeline .addFirst (defaultEventExecutorGroup , "sslHandler" , sslContext .newHandler (ch .alloc ()));
176
176
log .info ("Prepend SSL handler" );
You can’t perform that action at this time.
0 commit comments