|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.remote.RemoteTransport
public abstract class RemoteTransport
INTERNAL API
The remote transport is responsible for sending and receiving messages. Each transport has an address, which it should provide in Serialization.currentTransportInformation (thread-local) while serializing actor references (which might also be part of messages). This address must be available (i.e. fully initialized) by the time the first message is received or when the start() method returns, whatever happens first.
Constructor Summary | |
---|---|
RemoteTransport(ExtendedActorSystem system,
RemoteActorRefProvider provider)
|
Method Summary | |
---|---|
abstract scala.collection.immutable.Set<Address> |
addresses()
Address to be used in RootActorPath of refs generated for this transport. |
abstract Address |
defaultAddress()
The default transport address of the actorsystem |
abstract Address |
localAddressForRemote(Address remote)
Resolves the correct local address to be used for contacting the given remote address |
abstract LoggingAdapter |
log()
A Logger that can be used to log issues that may occur |
protected abstract 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. |
RemoteActorRefProvider |
provider()
|
abstract void |
quarantine(Address address,
scala.Option<java.lang.Object> uid)
Marks a remote system as out of sync and prevents reconnects until the quarantine timeout elapses. |
abstract void |
send(java.lang.Object message,
scala.Option<ActorRef> senderOption,
RemoteActorRef recipient)
Sends the given message to the recipient supplying the sender() if any |
abstract scala.concurrent.Future<scala.runtime.BoxedUnit> |
shutdown()
Shuts down the remoting |
abstract void |
start()
Start up the transport, i.e. |
ExtendedActorSystem |
system()
|
protected abstract boolean |
useUntrustedMode()
When this method returns true, some functionality will be turned off for security purposes. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RemoteTransport(ExtendedActorSystem system, RemoteActorRefProvider provider)
Method Detail |
---|
public ExtendedActorSystem system()
public RemoteActorRefProvider provider()
public abstract scala.concurrent.Future<scala.runtime.BoxedUnit> shutdown()
public abstract scala.collection.immutable.Set<Address> addresses()
public abstract Address defaultAddress()
public abstract Address localAddressForRemote(Address remote)
remote
- the remote address
public abstract void start()
public abstract void send(java.lang.Object message, scala.Option<ActorRef> senderOption, RemoteActorRef recipient)
message
- (undocumented)senderOption
- (undocumented)recipient
- (undocumented)public scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)
cmd
- Command message to send to the transports.
public abstract LoggingAdapter log()
public abstract void quarantine(Address address, scala.Option<java.lang.Object> uid)
address
- 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 abstract boolean useUntrustedMode()
protected abstract boolean logRemoteLifeCycleEvents()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |