public class Remoting extends RemoteTransport
Modifier and Type | Class and Description |
---|---|
static class |
Remoting.RegisterTransportActor |
static class |
Remoting.RegisterTransportActor$ |
static class |
Remoting.TransportSupervisor |
Constructor and Description |
---|
Remoting(akka.actor.ExtendedActorSystem _system,
RemoteActorRefProvider _provider) |
Modifier and Type | Method and Description |
---|---|
scala.collection.immutable.Set<akka.actor.Address> |
addresses()
Address to be used in RootActorPath of refs generated for this transport.
|
scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Set<akka.actor.Address>> |
boundAddresses() |
akka.actor.Address |
defaultAddress()
The default transport address of the ActorSystem
|
static java.lang.String |
EndpointManagerName() |
EventPublisher |
eventPublisher() |
akka.actor.Address |
localAddressForRemote(akka.actor.Address remote)
Resolves the correct local address to be used for contacting the given remote address
|
akka.event.LoggingAdapter |
log()
A Logger that can be used to log issues that may occur
|
scala.concurrent.Future<java.lang.Object> |
managementCommand(java.lang.Object cmd)
Sends a management command to the underlying transport stack.
|
void |
quarantine(akka.actor.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<akka.actor.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.
|
akka.actor.ActorRef |
transportSupervisor() |
protected boolean |
useUntrustedMode()
When this method returns true, some functionality will be turned off for security purposes.
|
provider, system
public Remoting(akka.actor.ExtendedActorSystem _system, RemoteActorRefProvider _provider)
public static final java.lang.String EndpointManagerName()
public scala.collection.immutable.Set<akka.actor.Address> addresses()
RemoteTransport
addresses
in class RemoteTransport
public akka.actor.Address defaultAddress()
RemoteTransport
defaultAddress
in class RemoteTransport
public akka.actor.ActorRef transportSupervisor()
public akka.actor.Address localAddressForRemote(akka.actor.Address remote)
RemoteTransport
localAddressForRemote
in class RemoteTransport
remote
- the remote addresspublic akka.event.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<akka.actor.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(akka.actor.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
public scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Set<akka.actor.Address>> boundAddresses()