akka.zeromq
Class Unsubscribe

java.lang.Object
  akka.zeromq.Unsubscribe

All Implemented Interfaces:

PubSubOption, Request, SocketOption, java.io.Serializable, scala.Equals, scala.Product

public class Unsubscribe
extends java.lang.Object
implements PubSubOption, scala.Product, scala.Serializable

The Unsubscribe option shall remove an existing message filter on a akka.zeromq.SocketType.Sub socket. The filter specified must match an existing filter previously established with the Subscribe option. If the socket has several instances of the same filter attached the Unsubscribe option shall remove only one instance, leaving the rest in place and functional.

param: payload

See Also:

Serialized Form

Constructor Summary

Unsubscribe(ByteString payload)

Unsubscribe(java.lang.String topic)

Method Summary

static Unsubscribe	apply(java.lang.String topic)
ByteString	payload()

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

Unsubscribe

public Unsubscribe(ByteString payload)

Unsubscribe

public Unsubscribe(java.lang.String topic)

Method Detail

apply

public static Unsubscribe apply(java.lang.String topic)

payload

public ByteString payload()

Specified by:

payload in interface PubSubOption