Package akka.remote

Class RemoteTransport

  • Direct Known Subclasses:
    ArteryTransport, Remoting

    public abstract class RemoteTransport
    extends java.lang.Object
    Shuts down the remoting
    • Method Detail

      • addresses

        public abstract scala.collection.immutable.Set<Address> addresses()
        Address to be used in RootActorPath of refs generated for this transport.
      • defaultAddress

        public abstract Address defaultAddress()
        The default transport address of the ActorSystem
        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
        remote - the remote address
        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
      • 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.
        cmd - Command message to send to the transports.
        A Future that indicates when the message was successfully handled or dropped.
      • 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.
        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
        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.