Package akka.remote

Class RemoteTransport

java.lang.Object

akka.remote.RemoteTransport

Direct Known Subclasses:

ArteryTransport, Remoting

public abstract class RemoteTransport
extends java.lang.Object

Shuts down the remoting

Constructor Summary

Constructors

Constructor	Description
RemoteTransport(ExtendedActorSystem system, RemoteActorRefProvider provider)

Method Summary

Modifier and Type	Method	Description
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
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, java.lang.String reason)	Marks a remote system as out of sync and prevents reconnects until the quarantine timeout elapses.
abstract void	send(java.lang.Object message, OptionVal<ActorRef> senderOption, RemoteActorRef recipient)	Sends the given message to the recipient supplying the sender() if any
abstract scala.concurrent.Future<Done>	shutdown()
abstract void	start()	Start up the transport, i.e.
ExtendedActorSystem	system()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RemoteTransport

public RemoteTransport(ExtendedActorSystem system,
                       RemoteActorRefProvider provider)

Method Detail

addresses

public abstract scala.collection.immutable.Set<Address> addresses()

Address to be used in RootActorPath of refs generated for this transport.

Returns:

(undocumented)

defaultAddress

public abstract Address defaultAddress()

The default transport address of the ActorSystem

Returns:

The listen address of the default transport

localAddressForRemote

public abstract Address localAddressForRemote(Address remote)

Resolves the correct local address to be used for contacting the given remote address

Parameters:

remote - the remote address

Returns:

the local address to be used for the given remote address

log

public abstract LoggingAdapter log()

A Logger that can be used to log issues that may occur

Returns:

(undocumented)

managementCommand

public scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)

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.

Parameters:

cmd - Command message to send to the transports.

Returns:

A Future that indicates when the message was successfully handled or dropped.

provider

public RemoteActorRefProvider provider()

quarantine

public abstract void quarantine(Address address,
                                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.

Parameters:

address - Address of the remote system to be quarantined

uid - 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 gated

reason - (undocumented)

send

public abstract void send(java.lang.Object message,
                          OptionVal<ActorRef> senderOption,
                          RemoteActorRef recipient)

Sends the given message to the recipient supplying the sender() if any

Parameters:

message - (undocumented)

senderOption - (undocumented)

recipient - (undocumented)

shutdown

public abstract scala.concurrent.Future<Done> shutdown()

start

public abstract void start()

Start up the transport, i.e. enable incoming connections.

system

public ExtendedActorSystem system()