#1982 - Opening up the send and notifyListeners methods on RemoteTransport so 3rd parties can extend it properly

This commit is contained in:
Viktor Klang 2012-04-08 00:25:53 +02:00
parent 6f6979412c
commit 2bb9e79b98
2 changed files with 5 additions and 5 deletions

View file

@ -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)
}

View file

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