akka.zeromq
Class ZeroMQ

java.lang.Object
  akka.zeromq.ZeroMQ

public class ZeroMQ
extends java.lang.Object

Java API for akka.zeromq

Constructor Summary

ZeroMQ()

Method Summary

static Affinity$	affinity() The message to ask a ZeroMQ socket for its affinity configuration.
static Backlog$	backlog() The message to ask a ZeroMQ socket for its backlog configuration.
static Closed$	closed() The message that is sent when an ZeroMQ socket disconnects.
static Connecting$	connecting() The message that is sent when an ZeroMQ socket connects.
static FileDescriptor$	fileDescriptor() The message to ask a ZeroMQ socket for its file descriptor configuration.
static Identity$	identity() The message to ask a ZeroMQ socket for its identity configuration.
static Linger$	linger() The message to ask a ZeroMQ socket for its linger configuration.
static MaxMsgSize$	maxMessageSize() The message to ask a ZeroMQ socket for its max message size configuration.
static MulticastHops$	multicastHops() The message to ask a ZeroMQ socket for its multicast hops configuration.
static MulticastLoop$	multicastLoop() The message to ask a ZeroMQ socket for its multicast loop configuration.
static Rate$	rate() The message to ask a ZeroMQ socket for its rate configuration.
static ReceiveBufferSize$	receiveBufferSize() The message to ask a ZeroMQ socket for its receive bufferSize configuration.
static ReceiveHighWatermark$	receiveHighWatermark() The message to ask a ZeroMQ socket for its receive high watermark configuration.
static ReconnectIVL$	reconnectIVL() The message to ask a ZeroMQ socket for its reconnect interval configuration.
static ReconnectIVLMax$	reconnectIVLMax() The message to ask a ZeroMQ socket for its max reconnect interval configuration.
static RecoveryInterval$	recoveryInterval() The message to ask a ZeroMQ socket for its recovery interval configuration.
static SendBufferSize$	sendBufferSize() The message to ask a ZeroMQ socket for its send buffer size configuration.
static SendHighWatermark$	sendHighWatermark() The message to ask a ZeroMQ socket for its send high watermark configuration.
static Swap$	swap() The message to ask a ZeroMQ socket for its swap configuration.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZeroMQ

public ZeroMQ()

Method Detail

connecting

public static Connecting$ connecting()

The message that is sent when an ZeroMQ socket connects.

 if (message == connecting()) {
   // Socket connected
 }
 

Returns:

the single instance of Connecting

closed

public static Closed$ closed()

The message that is sent when an ZeroMQ socket disconnects.

 if (message == closed()) {
   // Socket disconnected
 }
 

Returns:

the single instance of Closed

affinity

public static Affinity$ affinity()

The message to ask a ZeroMQ socket for its affinity configuration.

 socket.ask(affinity())
 

Returns:

the single instance of Affinity

backlog

public static Backlog$ backlog()

The message to ask a ZeroMQ socket for its backlog configuration.

 socket.ask(backlog())
 

Returns:

the single instance of Backlog

fileDescriptor

public static FileDescriptor$ fileDescriptor()

The message to ask a ZeroMQ socket for its file descriptor configuration.

 socket.ask(fileDescriptor())
 

Returns:

the single instance of FileDescriptor

identity

public static Identity$ identity()

The message to ask a ZeroMQ socket for its identity configuration.

 socket.ask(identity())
 

Returns:

the single instance of Identity

linger

public static Linger$ linger()

The message to ask a ZeroMQ socket for its linger configuration.

 socket.ask(linger())
 

Returns:

the single instance of Linger

maxMessageSize

public static MaxMsgSize$ maxMessageSize()

The message to ask a ZeroMQ socket for its max message size configuration.

 socket.ask(maxMessageSize())
 

Returns:

the single instance of MaxMsgSize

multicastHops

public static MulticastHops$ multicastHops()

The message to ask a ZeroMQ socket for its multicast hops configuration.

 socket.ask(multicastHops())
 

Returns:

the single instance of MulticastHops

multicastLoop

public static MulticastLoop$ multicastLoop()

The message to ask a ZeroMQ socket for its multicast loop configuration.

 socket.ask(multicastLoop())
 

Returns:

the single instance of MulticastLoop

rate

public static Rate$ rate()

The message to ask a ZeroMQ socket for its rate configuration.

 socket.ask(rate())
 

Returns:

the single instance of Rate

receiveBufferSize

public static ReceiveBufferSize$ receiveBufferSize()

The message to ask a ZeroMQ socket for its receive bufferSize configuration.

 socket.ask(receiveBufferSize())
 

Returns:

the single instance of ReceiveBufferSize

receiveHighWatermark

public static ReceiveHighWatermark$ receiveHighWatermark()

The message to ask a ZeroMQ socket for its receive high watermark configuration.

 socket.ask(receiveHighWatermark())
 

Returns:

the single instance of ReceiveHighWatermark

reconnectIVL

public static ReconnectIVL$ reconnectIVL()

The message to ask a ZeroMQ socket for its reconnect interval configuration.

 socket.ask(reconnectIVL())
 

Returns:

the single instance of ReconnectIVL

reconnectIVLMax

public static ReconnectIVLMax$ reconnectIVLMax()

The message to ask a ZeroMQ socket for its max reconnect interval configuration.

 socket.ask(reconnectIVLMax())
 

Returns:

the single instance of ReconnectIVLMax

recoveryInterval

public static RecoveryInterval$ recoveryInterval()

The message to ask a ZeroMQ socket for its recovery interval configuration.

 socket.ask(recoveryInterval())
 

Returns:

the single instance of RecoveryInterval

sendBufferSize

public static SendBufferSize$ sendBufferSize()

The message to ask a ZeroMQ socket for its send buffer size configuration.

 socket.ask(sendBufferSize())
 

Returns:

the single instance of SendBufferSize

sendHighWatermark

public static SendHighWatermark$ sendHighWatermark()

The message to ask a ZeroMQ socket for its send high watermark configuration.

 socket.ask(sendHighWatermark())
 

Returns:

the single instance of SendHighWatermark

swap

public static Swap$ swap()

The message to ask a ZeroMQ socket for its swap configuration.

 socket.ask(swap())
 

Returns:

the single instance of Swap