|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.remote.RemoteTransport akka.remote.Remoting
public class Remoting
INTERNAL API
Nested Class Summary | |
---|---|
static class |
Remoting.RegisterTransportActor
|
static class |
Remoting.RegisterTransportActor$
|
static class |
Remoting.TransportSupervisor
|
Constructor Summary | |
---|---|
Remoting(ExtendedActorSystem _system,
RemoteActorRefProvider _provider)
|
Method Summary | |
---|---|
scala.collection.immutable.Set<Address> |
addresses()
Address to be used in RootActorPath of refs generated for this transport. |
Address |
defaultAddress()
The default transport address of the actorsystem |
static java.lang.String |
EndpointManagerName()
|
EventPublisher |
eventPublisher()
|
Address |
localAddressForRemote(Address remote)
Resolves the correct local address to be used for contacting the given remote address |
LoggingAdapter |
log()
A Logger that can be used to log issues that may occur |
protected boolean |
logRemoteLifeCycleEvents()
When this method returns true, RemoteLifeCycleEvents will be logged as well as be put onto the eventStream. |
scala.concurrent.Future<java.lang.Object> |
managementCommand(java.lang.Object cmd)
Sends a management command to the underlying transport stack. |
void |
quarantine(Address remoteAddress,
scala.Option<java.lang.Object> uid)
Marks a remote system as out of sync and prevents reconnects until the quarantine timeout elapses. |
void |
send(java.lang.Object message,
scala.Option<ActorRef> senderOption,
RemoteActorRef recipient)
Sends the given message to the recipient supplying the sender() if any |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
shutdown()
Shuts down the remoting |
void |
start()
Start up the transport, i.e. |
ActorRef |
transportSupervisor()
|
protected boolean |
useUntrustedMode()
When this method returns true, some functionality will be turned off for security purposes. |
Methods inherited from class akka.remote.RemoteTransport |
---|
provider, system |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public Remoting(ExtendedActorSystem _system, RemoteActorRefProvider _provider)
Method Detail |
---|
public static final java.lang.String EndpointManagerName()
public scala.collection.immutable.Set<Address> addresses()
RemoteTransport
addresses
in class RemoteTransport
public Address defaultAddress()
RemoteTransport
defaultAddress
in class RemoteTransport
public ActorRef transportSupervisor()
public Address localAddressForRemote(Address remote)
RemoteTransport
localAddressForRemote
in class RemoteTransport
remote
- the remote address
public LoggingAdapter log()
RemoteTransport
log
in class RemoteTransport
public EventPublisher eventPublisher()
public scala.concurrent.Future<scala.runtime.BoxedUnit> shutdown()
RemoteTransport
shutdown
in class RemoteTransport
public void start()
RemoteTransport
start
in class RemoteTransport
public void send(java.lang.Object message, scala.Option<ActorRef> senderOption, RemoteActorRef recipient)
RemoteTransport
send
in class RemoteTransport
message
- (undocumented)senderOption
- (undocumented)recipient
- (undocumented)public scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)
RemoteTransport
managementCommand
in class RemoteTransport
cmd
- Command message to send to the transports.
public void quarantine(Address remoteAddress, scala.Option<java.lang.Object> uid)
RemoteTransport
quarantine
in class RemoteTransport
remoteAddress
- Address of the remote system to be quarantineduid
- UID of the remote system, if the uid is not defined it will not be a strong quarantine but
the current endpoint writer will be stopped (dropping system messages) and the address will be gatedprotected boolean useUntrustedMode()
RemoteTransport
useUntrustedMode
in class RemoteTransport
protected boolean logRemoteLifeCycleEvents()
RemoteTransport
logRemoteLifeCycleEvents
in class RemoteTransport
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |