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

    Returns a newly created AkkaRemoteProtocol with the given message payload.

    Returns a newly created AkkaRemoteProtocol with the given message payload.

    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. def logRemoteLifeCycleEvents: Boolean

    When this method returns true, RemoteLifeCycleEvents will be logged as well as be put onto the eventStream.

    When this method returns true, RemoteLifeCycleEvents will be logged as well as be put onto the eventStream.

    Attributes
    protected
    Definition Classes
    NettyRemoteTransportRemoteMarshallingOpsRemoteTransport
  23. final def ne(arg0: AnyRef): Boolean

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

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

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

    Definition Classes
    RemoteTransport
  27. val provider: RemoteActorRefProvider

  28. def receiveMessage(remoteMessage: RemoteMessage): Unit

    Definition Classes
    RemoteMarshallingOps
  29. val remoteSettings: RemoteSettings

  30. 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
  31. 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
  32. val server: NettyRemoteServer

  33. val settings: NettySettings

  34. def shutdown(): Unit

    Shuts down the remoting

    Shuts down the remoting

    Definition Classes
    NettyRemoteTransportRemoteTransport
  35. 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
  36. def start(): Unit

    Start up the transport, i.

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

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

    Definition Classes
    AnyRef
  38. 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
  39. val timer: HashedWheelTimer

  40. 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
  41. def toString(): String

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

  43. def useUntrustedMode: Boolean

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from RemoteMarshallingOps

Inherited from RemoteTransport

Inherited from AnyRef

Inherited from Any