#1982 - Opening up the send and notifyListeners methods on RemoteTran…

…sport so 3rd parties can extend it properly
akka · Apr 7, 2012 · bc3e2ce · bc3e2ce
1 parent 19efd96
commit bc3e2ce
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git 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, "REMOTE: {}", 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
@@ -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 = {