raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Adding SSL code to RemoteServer

Browse source
This commit is contained in:
Viktor Klang 2010-04-25 20:40:47 +02:00
parent f252aef9c8
commit 53f11d0d2c
1 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-core/src/main/scala/remote/RemoteServer.scala
View file

@ -367,7 +367,14 @@ class RemoteServerHandler(
val sslHandler : SslHandler = ctx.getPipeline.get(classOf[SslHandler]) val sslHandler : SslHandler = ctx.getPipeline.get(classOf[SslHandler])
// Begin handshake. // 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
}
})
} }