akka.remote.netty

NettyRemoteTransport

class NettyRemoteTransport extends RemoteTransport with RemoteMarshallingOps

Provides the implementation of the Netty remote support

Annotations
@deprecated
Deprecated

(Since version 2.0.2) Will become private[akka] in 2.1, this is not user-api

Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. NettyRemoteTransport
  2. RemoteMarshallingOps
  3. RemoteTransport
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new NettyRemoteTransport(remoteSettings: RemoteSettings, system: ActorSystemImpl, provider: RemoteActorRefProvider)

Value Members

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

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. def address: Address

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

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

    Definition Classes
    NettyRemoteTransportRemoteMarshallingOpsRemoteTransport
  7. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  8. def bindClient(remoteAddress: Address, client: RemoteClient, putIfAbsent: Boolean = false): Boolean

  9. val clientChannelFactory: NioClientSocketChannelFactory

  10. def clone(): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  11. def createControlEnvelope(rcp: RemoteControlProtocol): AkkaRemoteProtocol

    Definition Classes
    RemoteMarshallingOps
  12. def createMessageSendEnvelope(rmp: RemoteMessageProtocol): AkkaRemoteProtocol

    Definition Classes
    RemoteMarshallingOps
  13. def createRemoteMessageProtocolBuilder(recipient: ActorRef, message: Any, senderOption: Option[ActorRef]): Builder

    Definition Classes
    RemoteMarshallingOps
  14. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  16. val executor: OrderedMemoryAwareThreadPoolExecutor

  17. def finalize(): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  18. final def getClass(): java.lang.Class[_]

    Definition Classes
    AnyRef → Any
  19. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  20. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  21. val log: LoggingAdapter

  22. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  23. final def notify(): Unit

    Definition Classes
    AnyRef
  24. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  25. def notifyListeners(message: RemoteLifeCycleEvent): Unit

    Definition Classes
    RemoteTransport
  26. val provider: RemoteActorRefProvider

  27. def receiveMessage(remoteMessage: RemoteMessage): Unit

    Definition Classes
    RemoteMarshallingOps
  28. val remoteSettings: RemoteSettings

  29. def restartClientConnection(remoteAddress: Address): Boolean

    Restarts a specific client connected to the supplied remote address, but only if the client is not shut down

    Restarts a specific client connected to the supplied remote address, but only if the client is not shut down

    Definition Classes
    NettyRemoteTransportRemoteTransport
  30. def send(message: Any, senderOption: Option[ActorRef], recipient: RemoteActorRef): Unit

    Methods that needs to be implemented by a transport *

    Methods that needs to be implemented by a transport *

    Definition Classes
    NettyRemoteTransportRemoteTransport
  31. val server: NettyRemoteServer

  32. val settings: NettySettings

  33. def shutdown(): Unit

    Shuts down the remoting

    Shuts down the remoting

    Definition Classes
    NettyRemoteTransportRemoteTransport
  34. def shutdownClientConnection(remoteAddress: Address): Boolean

    Shuts down a specific client connected to the supplied remote address returns true if successful

    Shuts down a specific client connected to the supplied remote address returns true if successful

    Definition Classes
    NettyRemoteTransportRemoteTransport
  35. def start(): Unit

    Start up the transport, i.

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

    Definition Classes
    NettyRemoteTransportRemoteTransport
  36. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  37. val system: ActorSystemImpl

    The actor system, for which this transport is instantiated.

    The actor system, for which this transport is instantiated. Will publish to its eventStream.

    Definition Classes
    NettyRemoteTransportRemoteMarshallingOpsRemoteTransport
  38. val timer: HashedWheelTimer

  39. def toRemoteActorRefProtocol(actor: ActorRef): ActorRefProtocol

    Serializes the ActorRef instance into a Protocol Buffers (protobuf) Message.

    Serializes the ActorRef instance into a Protocol Buffers (protobuf) Message.

    Definition Classes
    RemoteMarshallingOps
  40. def toString(): String

    Definition Classes
    RemoteTransport → AnyRef → Any
  41. def unbindClient(remoteAddress: Address): Unit

  42. def useUntrustedMode: Boolean

    Attributes
    protected
    Definition Classes
    NettyRemoteTransportRemoteMarshallingOps
  43. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  44. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()
  45. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from RemoteMarshallingOps

Inherited from RemoteTransport

Inherited from AnyRef

Inherited from Any