Package akka.remote
Class Remoting
- java.lang.Object
-
- akka.remote.RemoteTransport
-
- akka.remote.Remoting
-
public class Remoting extends RemoteTransport
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Remoting.RegisterTransportActor
static class
Remoting.RegisterTransportActor$
static class
Remoting.TransportSupervisor
-
Constructor Summary
Constructors Constructor Description Remoting(ExtendedActorSystem _system, RemoteActorRefProvider _provider)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.collection.immutable.Set<Address>
addresses()
Address to be used in RootActorPath of refs generated for this transport.void
addresses_$eq(scala.collection.immutable.Set<Address> x$1)
scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Set<Address>>
boundAddresses()
Address
defaultAddress()
The default transport address of the ActorSystemvoid
defaultAddress_$eq(Address x$1)
static java.lang.String
EndpointManagerName()
EventPublisher
eventPublisher()
Address
localAddressForRemote(Address remote)
Resolves the correct local address to be used for contacting the given remote addressLoggingAdapter
log()
A Logger that can be used to log issues that may occurscala.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, java.lang.String reason)
Marks a remote system as out of sync and prevents reconnects until the quarantine timeout elapses.void
send(java.lang.Object message, OptionVal<ActorRef> senderOption, RemoteActorRef recipient)
Sends the given message to the recipient supplying the sender() if anyscala.concurrent.Future<Done>
shutdown()
void
start()
Start up the transport, i.e.ActorRef
transportSupervisor()
-
Methods inherited from class akka.remote.RemoteTransport
provider, system
-
-
-
-
Constructor Detail
-
Remoting
public Remoting(ExtendedActorSystem _system, RemoteActorRefProvider _provider)
-
-
Method Detail
-
EndpointManagerName
public static final java.lang.String EndpointManagerName()
-
addresses
public scala.collection.immutable.Set<Address> addresses()
Description copied from class:RemoteTransport
Address to be used in RootActorPath of refs generated for this transport.- Specified by:
addresses
in classRemoteTransport
- Returns:
- (undocumented)
-
addresses_$eq
public void addresses_$eq(scala.collection.immutable.Set<Address> x$1)
-
defaultAddress
public Address defaultAddress()
Description copied from class:RemoteTransport
The default transport address of the ActorSystem- Specified by:
defaultAddress
in classRemoteTransport
- Returns:
- The listen address of the default transport
-
defaultAddress_$eq
public void defaultAddress_$eq(Address x$1)
-
transportSupervisor
public ActorRef transportSupervisor()
-
localAddressForRemote
public Address localAddressForRemote(Address remote)
Description copied from class:RemoteTransport
Resolves the correct local address to be used for contacting the given remote address- Specified by:
localAddressForRemote
in classRemoteTransport
- Parameters:
remote
- the remote address- Returns:
- the local address to be used for the given remote address
-
log
public LoggingAdapter log()
Description copied from class:RemoteTransport
A Logger that can be used to log issues that may occur- Specified by:
log
in classRemoteTransport
- Returns:
- (undocumented)
-
eventPublisher
public EventPublisher eventPublisher()
-
shutdown
public scala.concurrent.Future<Done> shutdown()
- Specified by:
shutdown
in classRemoteTransport
-
start
public void start()
Description copied from class:RemoteTransport
Start up the transport, i.e. enable incoming connections.- Specified by:
start
in classRemoteTransport
-
send
public void send(java.lang.Object message, OptionVal<ActorRef> senderOption, RemoteActorRef recipient)
Description copied from class:RemoteTransport
Sends the given message to the recipient supplying the sender() if any- Specified by:
send
in classRemoteTransport
- Parameters:
message
- (undocumented)senderOption
- (undocumented)recipient
- (undocumented)
-
managementCommand
public scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)
Description copied from class:RemoteTransport
Sends a management command to the underlying transport stack. The call returns with a Future that indicates if the command was handled successfully or dropped.- Overrides:
managementCommand
in classRemoteTransport
- Parameters:
cmd
- Command message to send to the transports.- Returns:
- A Future that indicates when the message was successfully handled or dropped.
-
quarantine
public void quarantine(Address remoteAddress, scala.Option<java.lang.Object> uid, java.lang.String reason)
Description copied from class:RemoteTransport
Marks a remote system as out of sync and prevents reconnects until the quarantine timeout elapses.- Specified by:
quarantine
in classRemoteTransport
- Parameters:
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 gatedreason
- (undocumented)
-
boundAddresses
public scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Set<Address>> boundAddresses()
-
-