summaryrefslogtreecommitdiff
path: root/src/xsub.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-01-14 12:25:54 +0100
committerMartin Sustrik <sustrik@250bpm.com>2011-01-14 12:25:54 +0100
commit58c9830d90fc39727cec88e48f8985a499aa0ee7 (patch)
tree29aa7e22b287ce13d16be0b5855f17db815714e0 /src/xsub.hpp
parent8eae7d8507b1c96aec28bca20a157bb7537c3eb8 (diff)
XSUB socket has a subscription distributor
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/xsub.hpp')
-rw-r--r--src/xsub.hpp4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/xsub.hpp b/src/xsub.hpp
index 85f902c..e10b2c7 100644
--- a/src/xsub.hpp
+++ b/src/xsub.hpp
@@ -24,6 +24,7 @@
#include "trie.hpp"
#include "socket_base.hpp"
+#include "dist.hpp"
#include "fq.hpp"
namespace zmq
@@ -57,6 +58,9 @@ namespace zmq
// Fair queueing object for inbound pipes.
fq_t fq;
+ // Distributor mechanism for outbound messages (subscriptions).
+ dist_t dist;
+
// The repository of subscriptions.
trie_t subscriptions;