akka

zeromq

package zeromq

Visibility
  1. Public
  2. All

Type Members

  1. case class Affinity (value: Long) extends SocketOption with Product with Serializable

  2. case class Backlog (value: Long) extends SocketOption with Product with Serializable

  3. case class Bind (endpoint: String) extends Request with Product with Serializable

  4. case class Connect (endpoint: String) extends Request with Product with Serializable

  5. class Context extends AnyRef

  6. trait Deserializer extends AnyRef

  7. case class Frame (payload: Seq[Byte]) extends Product with Serializable

  8. case class HWM (value: Long) extends SocketOption with Product with Serializable

  9. case class Identity (value: Array[Byte]) extends SocketOption with Product with Serializable

  10. case class Linger (value: Long) extends SocketOption with Product with Serializable

  11. case class MaxMsgSize (value: Long) extends SocketOption with Product with Serializable

  12. case class MulticastHops (value: Long) extends SocketOption with Product with Serializable

  13. case class MulticastLoop (value: Boolean) extends SocketOption with Product with Serializable

  14. case class Rate (value: Long) extends SocketOption with Product with Serializable

  15. case class RcvHWM (value: Long) extends SocketOption with Product with Serializable

  16. case class ReceiveBufferSize (value: Long) extends SocketOption with Product with Serializable

  17. case class ReceiveTimeOut (value: Long) extends SocketOption with Product with Serializable

  18. case class ReconnectIVL (value: Long) extends SocketOption with Product with Serializable

  19. case class ReconnectIVLMax (value: Long) extends SocketOption with Product with Serializable

  20. case class RecoveryInterval (value: Long) extends SocketOption with Product with Serializable

  21. trait Request extends AnyRef

    Attributes
    sealed
  22. trait Response extends AnyRef

    Attributes
    sealed
  23. case class Send (frames: Seq[Frame]) extends Request with Product with Serializable

  24. case class SendBufferSize (value: Long) extends SocketOption with Product with Serializable

  25. case class SendTimeOut (value: Long) extends SocketOption with Product with Serializable

  26. case class SndHWM (value: Long) extends SocketOption with Product with Serializable

  27. trait SocketOption extends Request

    Attributes
    sealed
  28. trait SocketOptionQuery extends Request

    Attributes
    sealed
  29. case class SocketParameters (context: Context, socketType: SocketType, listener: Option[ActorRef], deserializer: Deserializer, pollTimeoutDuration: Duration) extends Product with Serializable

  30. case class Subscribe (payload: Seq[Byte]) extends Request with Product with Serializable

  31. case class Swap (value: Long) extends SocketOption with Product with Serializable

  32. case class Unsubscribe (payload: Seq[Byte]) extends Request with Product with Serializable

  33. case class ZMQMessage (frames: Seq[Frame]) extends Product with Serializable

  34. class ZMQMessageDeserializer extends Deserializer

  35. case class ZeroMQVersion (major: Int, minor: Int, patch: Int) extends Product with Serializable

Value Members

  1. object Affinity extends SocketOptionQuery with Serializable

  2. object Backlog extends SocketOptionQuery with Serializable

  3. object Closed extends Response with Product with Serializable

  4. object Connecting extends Response with Product with Serializable

  5. object FileDescriptor extends SocketOptionQuery

  6. object Frame extends Serializable

  7. object Identity extends SocketOptionQuery with Serializable

  8. object Linger extends SocketOptionQuery with Serializable

  9. object MaxMsgSize extends SocketOptionQuery with Serializable

  10. object MulticastHops extends SocketOptionQuery with Serializable

  11. object MulticastLoop extends SocketOptionQuery with Serializable

  12. object Rate extends SocketOptionQuery with Serializable

  13. object RcvHWM extends SocketOptionQuery with Serializable

  14. object ReceiveBufferSize extends SocketOptionQuery with Serializable

  15. object ReceiveMore extends SocketOptionQuery

  16. object ReceiveTimeOut extends SocketOptionQuery with Serializable

  17. object ReconnectIVL extends SocketOptionQuery with Serializable

  18. object ReconnectIVLMax extends SocketOptionQuery with Serializable

  19. object RecoveryInterval extends SocketOptionQuery with Serializable

  20. object SendBufferSize extends SocketOptionQuery with Serializable

  21. object SendTimeOut extends SocketOptionQuery with Serializable

  22. object SndHWM extends SocketOptionQuery with Serializable

  23. object SocketType extends Enumeration

  24. object Subscribe extends Serializable

  25. object Swap extends SocketOptionQuery with Serializable

  26. object Unsubscribe extends Serializable

  27. object ZMQMessage extends Serializable

  28. object ZeroMQ extends AnyRef