raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Shall not do that

Browse source
This commit is contained in:
Viktor Klang 2012-07-04 15:37:10 +02:00
parent f89285a19c
commit 6e9f6b12dc
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-zeromq/src/main/scala/akka/zeromq/SocketOption.scala
View file

@ -162,14 +162,14 @@ case class PollTimeoutDuration(duration: Duration = 100 millis) extends SocketMe
case class Bind(endpoint: String) extends SocketConnectOption case class Bind(endpoint: String) extends SocketConnectOption
/** /**
* The [[akka.zeromq.Subscribe]] option shall establish a new message filter on a [[akka.zeromq.SocketType.Pub]] socket. * The [[akka.zeromq.Subscribe]] option establishes a new message filter on a [[akka.zeromq.SocketType.Pub]] socket.
* Newly created [[akka.zeromq.SocketType.Sub]] sockets shall filter out all incoming messages, * Newly created [[akka.zeromq.SocketType.Sub]] sockets filter out all incoming messages,
* therefore you should send this option to establish an initial message filter. * therefore you should send this option to establish an initial message filter.
* *
* An empty payload of length zero shall subscribe to all incoming messages. * An empty payload of length zero will subscribe to all incoming messages.
* A non-empty payload shall subscribe to all messages beginning with the specified prefix. * A non-empty payload will subscribe to all messages beginning with the specified prefix.
* Multiple filters may be attached to a single [[akka.zeromq.SocketType.Sub]] socket, * Multiple filters may be attached to a single [[akka.zeromq.SocketType.Sub]] socket,
* in which case a message shall be accepted if it matches at least one filter. * in which case a message will be accepted if it matches at least one filter.
* *
* @param payload the topic to subscribe to * @param payload the topic to subscribe to
*/ */