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(ExtendedActorSystem _system,
RemoteActorRefProvider _provider) |
Modifier and Type | Method and Description |
---|---|
scala.collection.immutable.Set<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<Address>> |
boundAddresses() |
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
|
scala.concurrent.Future<java.lang.Object> |
managementCommand(java.lang.Object cmd)
Sends a management command to the underlying transport stack.
|
static RemoteActorRefProvider |
provider() |
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 any
|
scala.concurrent.Future<Done> |
shutdown()
Shuts down the remoting
|
void |
start()
Start up the transport, i.e.
|
static ExtendedActorSystem |
system() |
ActorRef |
transportSupervisor() |
provider, system
public Remoting(ExtendedActorSystem _system, RemoteActorRefProvider _provider)
public static final java.lang.String EndpointManagerName()
public static ExtendedActorSystem system()
public static RemoteActorRefProvider provider()
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 addresspublic LoggingAdapter log()
RemoteTransport
log
in class RemoteTransport
public EventPublisher eventPublisher()
public scala.concurrent.Future<Done> shutdown()
RemoteTransport
shutdown
in class RemoteTransport
public void start()
RemoteTransport
start
in class RemoteTransport
public void send(java.lang.Object message, OptionVal<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, java.lang.String reason)
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 gatedreason
- (undocumented)public scala.collection.immutable.Map<java.lang.String,scala.collection.immutable.Set<Address>> boundAddresses()