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

Minor code cleanup and deprecations etc

Browse source
This commit is contained in:
Viktor Klang 2011-01-05 16:36:50 +01:00
parent 2c613d99da
commit 71596343c6
4 changed files with 26 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

29
akka-actor/src/main/scala/akka/remoteinterface/RemoteInterface.scala
View file

@ -102,7 +102,7 @@ case class RemoteServerClientClosed(
case class RemoteServerWriteFailed(
@BeanProperty request: AnyRef,
@BeanProperty cause: Throwable,
@BeanProperty client: RemoteServerModule, remoteAddress: InetSocketAddress) extends RemoteServerLifeCycleEvent
@BeanProperty server: RemoteServerModule, remoteAddress: Option[InetSocketAddress]) extends RemoteServerLifeCycleEvent
/**
* Thrown for example when trying to send a message using a RemoteClient that is either not started or shut down.
@ -237,14 +237,27 @@ trait RemoteServerModule extends RemoteModule {
/**
* Starts the server up
*/
def start(host: String = ReflectiveAccess.Remote.configDefaultAddress.getHostName,
port: Int = ReflectiveAccess.Remote.configDefaultAddress.getPort,
loader: Option[ClassLoader] = None): RemoteServerModule
def start(): RemoteServerModule =
start(ReflectiveAccess.Remote.configDefaultAddress.getHostName,
ReflectiveAccess.Remote.configDefaultAddress.getPort)
/**
* Starts the server up
*/
def start(loader: ClassLoader): RemoteServerModule =
start(ReflectiveAccess.Remote.configDefaultAddress.getHostName,
ReflectiveAccess.Remote.configDefaultAddress.getPort,
Option(loader))
/**
* Starts the server up
*/
def start(host: String, port: Int, loader: Option[ClassLoader] = None): RemoteServerModule
/**
* Shuts the server down
*/
def shutdownServerModule: Unit
def shutdownServerModule(): Unit
/**
* Register typed actor by interface name.
@ -391,7 +404,7 @@ trait RemoteClientModule extends RemoteModule { self: RemoteModule =>
/**
* Clean-up all open connections.
*/
def shutdownClientModule: Unit
def shutdownClientModule(): Unit
/**
* Shuts down a specific client connected to the supplied remote address returns true if successful
@ -424,7 +437,7 @@ trait RemoteClientModule extends RemoteModule { self: RemoteModule =>
private[akka] def deregisterSupervisorForActor(actorRef: ActorRef): ActorRef
private[akka] def registerClientManagedActor(hostname: String, port: Int, uuid: Uuid): Unit
private[akka] def registerClientManagedActor(hostname: String, port: Int, uuid: Uuid): Unit
private[akka] def unregisterClientManagedActor(hostname: String, port: Int, uuid: Uuid): Unit
private[akka] def unregisterClientManagedActor(hostname: String, port: Int, uuid: Uuid): Unit
}