summaryrefslogtreecommitdiff
path: root/doc
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-06-19 16:39:27 +0200
committerMartin Sustrik <sustrik@250bpm.com>2011-06-19 16:39:27 +0200
commited680a395edb9260eced8289b33041248782f979 (patch)
tree9209ca7a657631b5eeb5293ad245bce3a718cd41 /doc
parent9f4d3767fed58ddfa52f63692c6169bfdbcec2e3 (diff)
Documentation for XPUB and XSUB socket added
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'doc')
-rw-r--r--doc/zmq_socket.txt41
1 files changed, 33 insertions, 8 deletions
diff --git a/doc/zmq_socket.txt b/doc/zmq_socket.txt
index b681147..badb9ef 100644
--- a/doc/zmq_socket.txt
+++ b/doc/zmq_socket.txt
@@ -80,7 +80,6 @@ messages are not discarded.
[horizontal]
.Summary of ZMQ_REQ characteristics
Compatible peer sockets:: 'ZMQ_REP'
-Direction:: Bidirectional
Send/receive pattern:: Send, Receive, Send, Receive, ...
Outgoing routing strategy:: Load-balanced
Incoming routing strategy:: Last peer
@@ -103,7 +102,6 @@ question shall be dropped until the exceptional state ends.
[horizontal]
.Summary of ZMQ_REP characteristics
Compatible peer sockets:: 'ZMQ_REQ'
-Direction:: Bidirectional
Send/receive pattern:: Receive, Send, Receive, Send, ...
Incoming routing strategy:: Fair-queued
Outgoing routing strategy:: Last peer
@@ -129,7 +127,6 @@ _body parts_.
[horizontal]
.Summary of ZMQ_XREQ characteristics
Compatible peer sockets:: 'ZMQ_XREP', 'ZMQ_REP'
-Direction:: Bidirectional
Send/receive pattern:: Unrestricted
Outgoing routing strategy:: Load-balanced
Incoming routing strategy:: Fair-queued
@@ -163,7 +160,6 @@ application must include the _delimiter_ part.
[horizontal]
.Summary of ZMQ_XREP characteristics
Compatible peer sockets:: 'ZMQ_XREQ', 'ZMQ_REQ'
-Direction:: Bidirectional
Send/receive pattern:: Unrestricted
Outgoing routing strategy:: See text
Incoming routing strategy:: Fair-queued
@@ -189,8 +185,7 @@ ends. The _zmq_send()_ function shall never block for this socket type.
[horizontal]
.Summary of ZMQ_PUB characteristics
-Compatible peer sockets:: 'ZMQ_SUB'
-Direction:: Unidirectional
+Compatible peer sockets:: 'ZMQ_SUB', 'ZMQ_XSUB'
Send/receive pattern:: Send only
Incoming routing strategy:: N/A
Outgoing routing strategy:: Fan out
@@ -207,14 +202,44 @@ implemented for this socket type.
[horizontal]
.Summary of ZMQ_SUB characteristics
-Compatible peer sockets:: 'ZMQ_PUB'
-Direction:: Unidirectional
+Compatible peer sockets:: 'ZMQ_PUB', 'ZMQ_XPUB'
Send/receive pattern:: Receive only
Incoming routing strategy:: Fair-queued
Outgoing routing strategy:: N/A
ZMQ_HWM option action:: Drop
+ZMQ_XPUB
+^^^^^^^^
+Same as ZMQ_PUB except that you can receive subscriptions from the peers
+in form of incoming messages. Subscription message is a byte 1 (for
+subscriptions) or byte 0 (for unsubscriptions) followed by the subscription
+body.
+
+[horizontal]
+.Summary of ZMQ_XPUB characteristics
+Compatible peer sockets:: 'ZMQ_SUB', 'ZMQ_XSUB'
+Send/receive pattern:: Send messages, receive subscriptions
+Incoming routing strategy:: N/A
+Outgoing routing strategy:: Fan out
+ZMQ_HWM option action:: Drop
+
+
+ZMQ_SUB
+^^^^^^^
+Same as ZMQ_SUB except that you subscribe by sending subscription messages to
+the socket. Subscription message is a byte 1 (for subscriptions) or byte 0
+(for unsubscriptions) followed by the subscription body.
+
+[horizontal]
+.Summary of ZMQ_XSUB characteristics
+Compatible peer sockets:: 'ZMQ_PUB', 'ZMQ_XPUB'
+Send/receive pattern:: Receive messages, send subscriptions
+Incoming routing strategy:: Fair-queued
+Outgoing routing strategy:: N/A
+ZMQ_HWM option action:: Drop
+
+
Pipeline pattern
~~~~~~~~~~~~~~~~
The pipeline pattern is used for distributing data to _nodes_ arranged in