Package akka.zeromq

Interface Summary

Deserializer	A base trait for message deserializers
PubSubOption	A base trait for pubsub options for the ZeroMQ socket
Request	Marker trait representing request messages for zeromq
Response	Base trait for the events raised by a ZeroMQ socket actor
SocketConnectOption	A base trait for connection options for a ZeroMQ socket
SocketMeta	Marker trait representing the base for all meta operations for a socket such as the context, listener, socket type and poller dispatcher
SocketOption	Marker trait representing the base for all socket options
SocketOptionQuery	A marker trait to group option queries together

Class Summary

Affinity	The Affinity option shall set the I/O thread affinity for newly created connections on the specified socket.
Affinity$	Gets the Affinity value
Backlog	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.
Backlog$	Gets the backlog
Bind	Start listening with this server socket on the specified address
Bind$
Closed	When the ZeroMQ socket disconnects it sends this message to a listener
Closed$	When the ZeroMQ socket disconnects it sends this message to a listener
Connect	This socket should be a client socket and connect to the specified endpoint
Connect$
Connecting	When the ZeroMQ socket connects it sends this message to a listener
Connecting$	When the ZeroMQ socket connects it sends this message to a listener
Context	Represents an I/O thread pool for ZeroMQ sockets.
Context$	Companion object for a ZeroMQ I/O thread pool
FileDescriptor	Gets the file descriptor associated with the ZeroMQ socket
FileDescriptor$	Gets the file descriptor associated with the ZeroMQ socket
Frame	A single message frame of a zeromq message
Frame$
HighWatermark	The HighWatermark option shall set the high water mark for the specified socket.
HighWatermark$
Identity	Sets the identity of the specified socket.
Identity$	Gets the Identity value
Linger	Configure this socket to have a linger of the specified value The linger period determines how long pending messages which have yet to be sent to a peer shall linger in memory after a socket is closed, and further affects the termination of the socket's context.
Linger$	Gets the linger option @see akka.zeromq.Linger
Listener	An option containing the listener for the socket
Listener$
MaxMsgSize	Limits the size of the inbound message.
MaxMsgSize$
MulticastHops	Sets the time-to-live field in every multicast packet sent from this socket.
MulticastHops$	Gets the MulticastHops
MulticastLoop	Controls whether data sent via multicast transports using the specified socket can also be received by the sending host via loop-back.
MulticastLoop$	Gets the MulticastLoop
PollDispatcher	An option containing the configuration key for the poller loop dispatcher
PollDispatcher$
PollTimeoutDuration	An option containing the duration a poll cycle should wait for a message before it loops
PollTimeoutDuration$
Rate	Sets the maximum send or receive data rate for multicast transports such as pgm using the specified socket.
Rate$	Gets the send or receive rate for the socket
ReceiveBufferSize	The ReceiveBufferSize option shall set the underlying kernel receive buffer size for the socket to the specified size in bytes.
ReceiveBufferSize$	Gets the ReceiveBufferSize
ReceiveHighWatermark	The ReceiveHighWatermark option shall set the high water mark for inbound messages on the specified socket.
ReceiveHighWatermark$	Gets the ReceiveHighWatermark
ReconnectIVL	Sets the recovery interval for multicast transports using the specified socket.
ReconnectIVL$	Gets the recover interval @see akka.zeromq.ReconnectIVL
ReconnectIVLMax	The ReconnectIVLMax option shall set the maximum reconnection interval for the specified socket.
ReconnectIVLMax$	Gets the max reconnect IVL
RecoveryInterval	Sets the recovery interval for multicast transports using the specified socket.
RecoveryInterval$	Gets the RecoveryInterval
Send	Send a message over the zeromq socket
Send$
SendBufferSize	The SendBufferSize option shall set the underlying kernel transmit buffer size for the socket to the specified size in bytes.
SendBufferSize$	Gets the SendBufferSize
SendHighWatermark	The SendHighWatermark option shall set the high water mark for outbound messages on the specified socket.
SendHighWatermark$	Gets the SendHWM
SocketType	The different socket types you can create with zeromq
SocketType.Dealer$	A dealer socket
SocketType.Pair$	A Pair socket
SocketType.Pub$	A Publisher socket
SocketType.Pull$	A pull socket
SocketType.Push$	A push socket
SocketType.Rep$	A reply socket
SocketType.Req$	A request socket
SocketType.Router$	A router socket
SocketType.Sub$	A subscriber socket
SocketType.ZMQSocketType
SocketType$	The different socket types you can create with zeromq
Subscribe	The Subscribe option establishes a new message filter on a akka.zeromq.SocketType.Pub socket.
Subscribe$
Swap	The Swap option shall set the disk offload (swap) size for the specified socket.
Swap$	Gets the Swap
Unsubscribe	The Unsubscribe option shall remove an existing message filter on a akka.zeromq.SocketType.Sub socket.
Unsubscribe$
ZeroMQ	Java API for akka.zeromq
ZeroMQ$	Java API for akka.zeromq
ZeroMQExtension	The extension for the ZeroMQ module
ZeroMQExtension$	The ExtensionId and ExtensionIdProvider for the ZeroMQ module
ZeroMQVersion	A Model to represent a version of the zeromq library
ZeroMQVersion$
ZMQMessage	A message received over the zeromq socket
ZMQMessage$	Convert the bytes in the first frame to a String, using "UTF-8" charset.
ZMQMessageDeserializer