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

Fixed compile errors

Browse source
This commit is contained in:
Endre Sándor Varga 2013-04-18 16:19:41 +02:00
parent 2b0a27be9e
commit da2a23f3e9
2 changed files with 2 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-remote/src/main/scala/akka/remote/transport/AkkaProtocolTransport.scala
View file

@ -115,7 +115,7 @@ private[transport] class AkkaProtocolManager(
val stateActorSettings = settings
val failureDetector = createTransportFailureDetector()
context.actorOf(Props(new ProtocolStateActor(
HandshakeInfo(stateActorLocalAddress, RARP(context.system).provider.addressUid, stateActorSettings.SecureCookie),
HandshakeInfo(stateActorLocalAddress, AddressUidExtension(context.system).addressUid, stateActorSettings.SecureCookie),
handle,
stateActorAssociationHandler,
stateActorSettings,
@ -128,7 +128,7 @@ private[transport] class AkkaProtocolManager(
val stateActorWrappedTransport = wrappedTransport
val failureDetector = createTransportFailureDetector()
context.actorOf(Props(new ProtocolStateActor(
HandshakeInfo(stateActorLocalAddress, RARP(context.system).provider.addressUid, stateActorSettings.SecureCookie),
HandshakeInfo(stateActorLocalAddress, AddressUidExtension(context.system).addressUid, stateActorSettings.SecureCookie),
remoteAddress,
statusPromise,
stateActorWrappedTransport,

4
akka-remote/src/test/scala/akka/remote/RemoteConfigSpec.scala
View file

@ -64,10 +64,6 @@ class RemoteConfigSpec extends AkkaSpec(
val settings = new AkkaProtocolSettings(RARP(system).provider.remoteSettings.config)
import settings._
WaitActivityEnabled must be(true)
FailureDetectorImplementationClass must be(classOf[PhiAccrualFailureDetector].getName)
AcceptableHeartBeatPause must be === 3.seconds
HeartBeatInterval must be === 1.seconds
RequireCookie must be(false)
SecureCookie must be === None