Commit 6647e612 authored by Martin Lucina's avatar Martin Lucina

Revert "Small improvements to zmq_device(3) page"

This reverts commit 96bcc9e6.
parent 83d253d7
...@@ -31,13 +31,16 @@ Before calling _zmq_device()_ you must set any socket options, and connect or ...@@ -31,13 +31,16 @@ Before calling _zmq_device()_ you must set any socket options, and connect or
bind both frontend and backend sockets. The two conventional device models bind both frontend and backend sockets. The two conventional device models
are: are:
* proxy model - accept inward connections to frontend socket (by binding it to *proxy*::
an endpoint), and make onward connections through backend socket (connecting bind frontend socket to an endpoint, and connect backend socket to
to endpoints on other nodes). A proxy device model can fit well into an downstream components. A proxy device model does not require changes to
existing topology. the downstream topology but that topology is static (any changes require
* broker model - accept connections on both frontend and backend sockets (by reconfiguring the device).
binding both to endpoints). A broker device model creates a star topology *broker*::
where nodes can come and go at any time. bind frontend socket to one endpoint and bind backend socket to a second
endpoint. Downstream components must now connect into the device. A
broker device model allows a dynamic downstream topology (components can
come and go at any time).
_zmq_device()_ runs in the current thread and returns only if/when the current _zmq_device()_ runs in the current thread and returns only if/when the current
context is closed. context is closed.
...@@ -118,21 +121,6 @@ assert (zmq_bind (backend, "tcp://*:5556") == 0); ...@@ -118,21 +121,6 @@ assert (zmq_bind (backend, "tcp://*:5556") == 0);
zmq_device (ZMQ_QUEUE, frontend, backend); zmq_device (ZMQ_QUEUE, frontend, backend);
---- ----
.Creating a pubsub proxy
----
// Create frontend and backend sockets
void *frontend = zmq_socket (context, ZMQ_SUB);
assert (backend);
void *backend = zmq_socket (context, ZMQ_PUB);
assert (frontend);
// Connect frontend to publisher
assert (zmq_bind (frontend, "tcp://192.68.55.112:4444") == 0);
// Bind backend to TCP port
assert (zmq_bind (backend, "tcp://*:5556") == 0);
// Start a forwarder device
zmq_device (ZMQ_FORWARDER, frontend, backend);
----
SEE ALSO SEE ALSO
-------- --------
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment