akka

zeromq

package zeromq

A package object with an implicit conversion for the actor system as a convenience

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. zeromq
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

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

    The akka.zeromq.Affinity option shall set the I/O thread affinity for newly created connections on the specified socket.

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

    The akka.zeromq.Backlog option shall set the maximum length of the queue of outstanding peer connections for the specified socket; this only applies to connection-oriented transports.

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

    Start listening with this server socket on the specified address

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

    This socket should be a client socket and connect to the specified endpoint

  5. class Context extends SocketMeta

    Represents an I/O thread pool for ZeroMQ sockets.

  6. trait Deserializer extends SocketOption

    A base trait for message deserializers

  7. case class HighWatermark(value: Long) extends SocketOption with Product with Serializable

    The akka.zeromq.HighWatermark option shall set the high water mark for the specified socket.

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

    Sets the identity of the specified socket.

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

    Configure this socket to have a linger of the specified value

  10. case class Listener(listener: ActorRef) extends SocketMeta with Product with Serializable

    An option containing the listener for the socket

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

    Limits the size of the inbound message.

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

    Sets the time-to-live field in every multicast packet sent from this socket.

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

    Controls whether data sent via multicast transports using the specified socket can also be received by the sending host via loop-back.

  14. case class PollDispatcher(name: String) extends SocketMeta with Product with Serializable

    An option containing the configuration key for the poller loop dispatcher

  15. case class PollTimeoutDuration(duration: FiniteDuration = ...) extends SocketMeta with Product with Serializable

    An option containing the duration a poll cycle should wait for a message before it loops

  16. sealed trait PubSubOption extends SocketOption

    A base trait for pubsub options for the ZeroMQ socket

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

    Sets the maximum send or receive data rate for multicast transports such as pgm using the specified socket.

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

    The akka.zeromq.ReceiveBufferSize option shall set the underlying kernel receive buffer size for the socket to the specified size in bytes.

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

    The akka.zeromq.ReceiveHighWatermark option shall set the high water mark for inbound messages on the specified socket.

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

    Sets the recovery interval for multicast transports using the specified socket.

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

    The akka.zeromq.ReconnectIVLMax option shall set the maximum reconnection interval for the specified socket.

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

    Sets the recovery interval for multicast transports using the specified socket.

  23. sealed trait Request extends AnyRef

    Marker trait representing request messages for zeromq

  24. sealed trait Response extends AnyRef

    Base trait for the events raised by a ZeroMQ socket actor

  25. case class Send(frames: Seq[ByteString]) extends Request with Product with Serializable

    Send a message over the zeromq socket

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

    The akka.zeromq.SendBufferSize option shall set the underlying kernel transmit buffer size for the socket to the specified size in bytes.

  27. case class SendHighWatermark(value: Long) extends SocketOption with Product with Serializable

    The akka.zeromq.SendHighWatermark option shall set the high water mark for outbound messages on the specified socket.

  28. sealed trait SocketConnectOption extends SocketOption

    A base trait for connection options for a ZeroMQ socket

  29. sealed trait SocketMeta extends SocketOption

    Marker trait representing the base for all meta operations for a socket such as the context, listener, socket type and poller dispatcher

  30. sealed trait SocketOption extends Request

    Marker trait representing the base for all socket options

  31. sealed trait SocketOptionQuery extends Request

    A marker trait to group option queries together

  32. case class Subscribe(payload: ByteString) extends PubSubOption with Product with Serializable

    The akka.zeromq.Subscribe option establishes a new message filter on a akka.zeromq.SocketType.Pub socket.

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

    The akka.zeromq.Swap option shall set the disk offload (swap) size for the specified socket.

  34. case class Unsubscribe(payload: ByteString) extends PubSubOption with Product with Serializable

    The akka.zeromq.Unsubscribe option shall remove an existing message filter on a akka.zeromq.SocketType.Sub socket.

  35. case class ZMQMessage(frames: Seq[ByteString]) extends Product with Serializable

    A message received over the zeromq socket

  36. class ZMQMessageDeserializer extends Deserializer

    Deserializes ZeroMQ messages into an immutable sequence of frames

  37. class ZeroMQExtension extends Extension

    The extension for the ZeroMQ module

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

    A Model to represent a version of the zeromq library

Value Members

  1. object Affinity extends SocketOptionQuery with Serializable

    Gets the akka.zeromq.Affinity value

  2. object Backlog extends SocketOptionQuery with Serializable

    Gets the backlog

  3. object Closed extends Response with Product with Serializable

    When the ZeroMQ socket disconnects it sends this message to a listener

  4. object Connecting extends Response with Product with Serializable

    When the ZeroMQ socket connects it sends this message to a listener

  5. object Context

    Companion object for a ZeroMQ I/O thread pool

  6. object FileDescriptor extends SocketOptionQuery

    Gets the file descriptor associated with the ZeroMQ socket

  7. object Identity extends SocketOptionQuery with Serializable

    Gets the akka.zeromq.Identity value

  8. object Linger extends SocketOptionQuery with Serializable

    Gets the linger option @see akka.zeromq.Linger

  9. object MaxMsgSize extends SocketOptionQuery with Serializable

  10. object MulticastHops extends SocketOptionQuery with Serializable

    Gets the akka.zeromq.MulticastHops

  11. object MulticastLoop extends SocketOptionQuery with Serializable

    Gets the akka.zeromq.MulticastLoop

  12. val NoLinger: Linger

    Set the linger to 0, doesn't block and discards messages that haven't been sent yet.

  13. object Rate extends SocketOptionQuery with Serializable

    Gets the send or receive rate for the socket

  14. object ReceiveBufferSize extends SocketOptionQuery with Serializable

    Gets the akka.zeromq.ReceiveBufferSize

  15. object ReceiveHighWatermark extends SocketOptionQuery with Serializable

    Gets the ReceiveHighWatermark

  16. object ReconnectIVL extends SocketOptionQuery with Serializable

    Gets the recover interval @see akka.zeromq.ReconnectIVL

  17. object ReconnectIVLMax extends SocketOptionQuery with Serializable

    Gets the max reconnect IVL

  18. object RecoveryInterval extends SocketOptionQuery with Serializable

    Gets the akka.zeromq.RecoveryInterval

  19. object SendBufferSize extends SocketOptionQuery with Serializable

    Gets the akka.zeromq.SendBufferSize

  20. object SendHighWatermark extends SocketOptionQuery with Serializable

    Gets the SendHWM

  21. object SocketType

    The different socket types you can create with zeromq

  22. object Subscribe extends Serializable

  23. val SubscribeAll: Subscribe

    Convenience accessor to subscribe to all events

  24. object Swap extends SocketOptionQuery with Serializable

    Gets the akka.zeromq.Swap

  25. object Unsubscribe extends Serializable

  26. object ZMQMessage extends Serializable

  27. object ZeroMQ

    Java API for akka.

  28. object ZeroMQExtension extends ExtensionId[ZeroMQExtension] with ExtensionIdProvider

    The akka.actor.ExtensionId and akka.actor.ExtensionIdProvider for the ZeroMQ module

Inherited from AnyRef

Inherited from Any

Ungrouped