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 = {