akka.zeromq
Class Identity

java.lang.Object
  extended by akka.zeromq.Identity
All Implemented Interfaces:
Request, SocketOption, java.io.Serializable, scala.Equals, scala.Product

public class Identity
extends java.lang.Object
implements SocketOption, scala.Product, scala.Serializable

Sets the identity of the specified socket. Socket identity determines if existing ØMQ infrastructure (message queues, forwarding devices) shall be identified with a specific application and persist across multiple runs of the application.

If the socket has no identity, each run of an application is completely separate from other runs. However, with identity set the socket shall re-use any existing ØMQ infrastructure configured by the previous run(s). Thus the application may receive messages that were sent in the meantime, message queue limits shall be shared with previous run(s) and so on.

Identity should be at least one byte and at most 255 bytes long. Identities starting with binary zero are reserved for use by ØMQ infrastructure.

param: value The identity string for this socket

See Also:
Serialized Form

Constructor Summary
Identity(byte[] value)
           
 
Method Summary
 byte[] value()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface scala.Product
productArity, productElement, productIterator, productPrefix
 
Methods inherited from interface scala.Equals
canEqual, equals
 

Constructor Detail

Identity

public Identity(byte[] value)
Method Detail

value

public byte[] value()