akka.zeromq
Class Identity

java.lang.Object
  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()