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

add previously forgotten TestConductorTransport

Browse source
This commit is contained in:
Roland 2012-05-05 15:16:21 +02:00
parent 9266ac451b
commit c68df0635f
1 changed files with 21 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

21
akka-remote/src/main/scala/akka/remote/testconductor/TestConductorTransport.scala Normal file
View file

@ -0,0 +1,21 @@
/**
* Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
*/
package akka.remote.testconductor
import akka.remote.netty.NettyRemoteTransport
import akka.remote.RemoteSettings
import akka.actor.ActorSystemImpl
import akka.remote.RemoteActorRefProvider
import org.jboss.netty.channel.ChannelHandler
import org.jboss.netty.channel.ChannelPipelineFactory
class TestConductorTransport(_remoteSettings: RemoteSettings, _system: ActorSystemImpl, _provider: RemoteActorRefProvider)
extends NettyRemoteTransport(_remoteSettings, _system, _provider) {
override def mkPipeline(endpoint: ⇒ ChannelHandler, withTimeout: Boolean): ChannelPipelineFactory =
new ChannelPipelineFactory {
def getPipeline = PipelineFactory(new NetworkFailureInjector(system) +: PipelineFactory.defaultStack(withTimeout) :+ endpoint)
}
}