From 2bb9e79b98fbaa731b5d1ac9706cdaf4fc6fb847 Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Sun, 8 Apr 2012 00:25:53 +0200 Subject: [PATCH] #1982 - Opening up the send and notifyListeners methods on RemoteTransport so 3rd parties can extend it properly --- .../src/main/scala/akka/remote/RemoteTransport.scala | 8 ++++---- .../main/scala/akka/remote/netty/NettyRemoteSupport.scala | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/akka-remote/src/main/scala/akka/remote/RemoteTransport.scala b/akka-remote/src/main/scala/akka/remote/RemoteTransport.scala index 92761ea2de..77bc8320c0 100644 --- a/akka-remote/src/main/scala/akka/remote/RemoteTransport.scala +++ b/akka-remote/src/main/scala/akka/remote/RemoteTransport.scala @@ -185,11 +185,11 @@ abstract class RemoteTransport { /** Methods that needs to be implemented by a transport **/ - protected[akka] def send(message: Any, - senderOption: Option[ActorRef], - recipient: RemoteActorRef): Unit + def send(message: Any, + senderOption: Option[ActorRef], + recipient: RemoteActorRef): Unit - protected[akka] def notifyListeners(message: RemoteLifeCycleEvent): Unit = { + def notifyListeners(message: RemoteLifeCycleEvent): Unit = { system.eventStream.publish(message) system.log.log(message.logLevel, "{}", message) } diff --git a/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala b/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala index 8acd33c7fb..42b319e4e5 100644 --- a/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala +++ b/akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala @@ -101,7 +101,7 @@ class NettyRemoteTransport(val remoteSettings: RemoteSettings, val system: Actor } } - protected[akka] def send( + def send( message: Any, senderOption: Option[ActorRef], recipient: RemoteActorRef): Unit = {