You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2021/07/28 07:42:35 UTC

[incubator-eventmesh] branch develop updated: [ISSUE #451] Fix SSLContext Initialize error (#458)

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

mikexue pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git


The following commit(s) were added to refs/heads/develop by this push:
     new b760873  [ISSUE #451] Fix SSLContext Initialize error (#458)
b760873 is described below

commit b76087365f3a1388ce899a6befe14b1f803726a0
Author: Wenjun Ruan <86...@qq.com>
AuthorDate: Wed Jul 28 15:42:25 2021 +0800

    [ISSUE #451] Fix SSLContext Initialize error (#458)
---
 .../java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java
index ac30667..26603e0 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/AbstractHTTPServer.java
@@ -154,9 +154,11 @@ public abstract class AbstractHTTPServer extends AbstractRemotingServer {
         super.start();
         Runnable r = () -> {
             ServerBootstrap b = new ServerBootstrap();
+            SSLContext sslContext = useTLS ? SSLContextFactory.getSslContext() : null;
             b.group(this.bossGroup, this.workerGroup)
                     .channel(NioServerSocketChannel.class)
-                    .childHandler(new HttpsServerInitializer(SSLContextFactory.getSslContext())).childOption(ChannelOption.SO_KEEPALIVE, Boolean.TRUE);
+                    .childHandler(new HttpsServerInitializer(sslContext))
+                    .childOption(ChannelOption.SO_KEEPALIVE, Boolean.TRUE);
             try {
                 httpServerLogger.info("HTTPServer[port={}] started......", this.port);
                 ChannelFuture future = b.bind(this.port).sync();

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org