From 53f11d0d2c399b2f7c5bd550b9264c70e6400027 Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Sun, 25 Apr 2010 20:40:47 +0200 Subject: [PATCH] Adding SSL code to RemoteServer --- akka-core/src/main/scala/remote/RemoteServer.scala | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/akka-core/src/main/scala/remote/RemoteServer.scala b/akka-core/src/main/scala/remote/RemoteServer.scala index 08c402f15a..2cd5a6dd4f 100644 --- a/akka-core/src/main/scala/remote/RemoteServer.scala +++ b/akka-core/src/main/scala/remote/RemoteServer.scala @@ -367,7 +367,14 @@ class RemoteServerHandler( val sslHandler : SslHandler = ctx.getPipeline.get(classOf[SslHandler]) // Begin handshake. - sslHandler.handshake() + sslHandler.handshake().addListener( new ChannelFutureListener { + def operationComplete(future : ChannelFuture) : Unit = { + if(future.isSuccess) + openChannels.add(future.getChannel) + else + future.getChannel.close + } + }) }