Package akka.remote

Class Remoting

    • 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 class RemoteTransport
        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 class RemoteTransport
        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 class RemoteTransport
        Parameters:
        remote - the remote address
        Returns:
        the local address to be used for the given remote address
      • start

        public void start()
        Description copied from class: RemoteTransport
        Start up the transport, i.e. enable incoming connections.
        Specified by:
        start in class RemoteTransport
      • 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 class RemoteTransport
        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 class RemoteTransport
        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 class RemoteTransport
        Parameters:
        remoteAddress - 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)
      • boundAddresses

        public scala.collection.immutable.Map<java.lang.String,​scala.collection.immutable.Set<Address>> boundAddresses()