akka.remote.netty

ActiveRemoteClient

class ActiveRemoteClient extends RemoteClient

RemoteClient represents a connection to an Akka node. Is used to send messages to remote actors on the node.

Linear Supertypes
RemoteClient, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. ActiveRemoteClient
  2. RemoteClient
  3. AnyRef
  4. Any
Visibility
  1. Public
  2. All

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any

  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

  7. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  8. def connect (reconnectIfAlreadyConnected: Boolean = false): Boolean

    Definition Classes
    ActiveRemoteClient → RemoteClient

  9. def currentChannel : Channel

    Definition Classes
    ActiveRemoteClient → RemoteClient

  10. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  11. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  12. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  13. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any

  14. def hashCode (): Int

    Definition Classes
    AnyRef → Any

  15. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any

  16. val loader : Option[ClassLoader]

    Definition Classes
    ActiveRemoteClient → RemoteClient

  17. val name : String

    Definition Classes
    RemoteClient

  18. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  19. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  20. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  21. def notifyListeners (msg: ⇒ Any): Unit

    Definition Classes
    ActiveRemoteClient → RemoteClient

  22. def pendingMessages : Array[Any]

    Returns an array with the current pending messages not yet delivered.

    Returns an array with the current pending messages not yet delivered.

    Definition Classes
    RemoteClient

  23. val resendMessageQueue : Queue[RemoteMessageProtocol]

    Attributes
    protected
    Definition Classes
    RemoteClient

  24. val resendMessageQueueLock : SimpleLock

    Attributes
    protected
    Definition Classes
    RemoteClient

  25. val resendMessagesOnFailure : Boolean

    Definition Classes
    RemoteClient

  26. val resendMessagesOnFailureCapacity : Int

    Definition Classes
    RemoteClient

  27. def send [T] (request: RemoteMessageProtocol, senderFuture: Option[CompletableFuture[T]]): Option[CompletableFuture[T]]

    Sends the message across the wire

    Sends the message across the wire

    Definition Classes
    RemoteClient

  28. def send [T] (message: Any, senderOption: Option[ActorRef], senderFuture: Option[CompletableFuture[T]], remoteAddress: InetSocketAddress, timeout: Long, isOneWay: Boolean, actorRef: ActorRef, typedActorInfo: Option[(String, String)], actorType: ActorType): Option[CompletableFuture[T]]

    Converts the message to the wireprotocol and sends the message across the wire

    Converts the message to the wireprotocol and sends the message across the wire

    Definition Classes
    RemoteClient

  29. def shutdown (): Boolean

    Definition Classes
    ActiveRemoteClient → RemoteClient

  30. val supervisors : ConcurrentHashMap[Uuid, ActorRef]

    Attributes
    protected
    Definition Classes
    RemoteClient

  31. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef

  32. def toString (): String

    Definition Classes
    AnyRef → Any

  33. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  34. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  35. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from RemoteClient

Inherited from AnyRef

Inherited from Any