akka

zeromq

package zeromq

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

Visibility
  1. Public
  2. All

Type Members

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

    The 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 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 Frame(payload: Seq[Byte]) extends Product with Serializable

    A single message frame of a zeromq message

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

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

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

    Sets the identity of the specified socket.

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

    Configure this socket to have a linger of the specified value

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

    An option containing the listener for the socket

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

    Limits the size of the inbound message.

  13. 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.

  14. 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.

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

    An option containing the configuration key for the poller loop dispatcher

  16. case class PollTimeoutDuration(duration: Duration) extends SocketMeta with Product with Serializable

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

  17. sealed trait PubSubOption extends SocketOption

    A base trait for pubsub options for the ZeroMQ socket

  18. 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.

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

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

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

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

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

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

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

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

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

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

  24. sealed trait Request extends AnyRef

    Marker trait representing request messages for zeromq

  25. sealed trait Response extends AnyRef

    Base trait for the events raised by a ZeroMQ socket actor

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

    Send a message over the zeromq socket

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

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

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

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

  29. sealed trait SocketConnectOption extends SocketOption

    A base trait for connection options for a ZeroMQ socket

  30. 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

  31. sealed trait SocketOption extends Request

    Marker trait representing the base for all socket options

  32. sealed trait SocketOptionQuery extends Request

    A marker trait to group option queries together

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

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

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

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

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

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

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

    A message received over the zeromq socket

  37. class ZMQMessageDeserializer extends Deserializer

    Deserializes ZeroMQ messages into an immutable sequence of frames

  38. class ZeroMQExtension extends Extension

    The extension for the ZeroMQ module

  39. 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 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 extends AnyRef

    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 Frame extends Serializable

  8. object Identity extends SocketOptionQuery with Serializable

    Gets the Identity value

  9. object Linger extends SocketOptionQuery with Serializable

    Gets the linger option @see Linger

  10. object MaxMsgSize extends SocketOptionQuery with Serializable

  11. object MulticastHops extends SocketOptionQuery with Serializable

    Gets the MulticastHops

  12. object MulticastLoop extends SocketOptionQuery with Serializable

    Gets the MulticastLoop

  13. val NoLinger: Linger

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

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

    Definition Classes
    package
  14. object Rate extends SocketOptionQuery with Serializable

    Gets the send or receive rate for the socket

  15. object ReceiveBufferSize extends SocketOptionQuery with Serializable

    Gets the ReceiveBufferSize

  16. object ReceiveHighWatermark extends SocketOptionQuery with Serializable

    Gets the ReceiveHighWatermark

  17. object ReconnectIVL extends SocketOptionQuery with Serializable

    Gets the recover interval @see ReconnectIVL

  18. object ReconnectIVLMax extends SocketOptionQuery with Serializable

    Gets the max reconnect IVL

  19. object RecoveryInterval extends SocketOptionQuery with Serializable

    Gets the RecoveryInterval

  20. object SendBufferSize extends SocketOptionQuery with Serializable

    Gets the SendBufferSize

  21. object SendHighWatermark extends SocketOptionQuery with Serializable

    Gets the SendHWM

  22. object SocketType extends AnyRef

    The different socket types you can create with zeromq

  23. object Subscribe extends Serializable

  24. val SubscribeAll: Subscribe

    Convenience accessor to subscribe to all events

    Convenience accessor to subscribe to all events

    Definition Classes
    package
  25. object Swap extends SocketOptionQuery with Serializable

    Gets the Swap

  26. object Unsubscribe extends Serializable

  27. object ZMQMessage extends Serializable

  28. object ZeroMQ extends AnyRef

    Java API for akka.

  29. object ZeroMQExtension extends ExtensionId[ZeroMQExtension] with ExtensionIdProvider

    The ExtensionId and ExtensionIdProvider for the ZeroMQ module

  30. implicit def zeromqSystem(system: ActorSystem): ZeroMQExtension

    Creates a zeromq actor system implicitly

    Creates a zeromq actor system implicitly

    system
    returns

    An augmented ActorSystem

    Definition Classes
    package