Fair queueing of subscriptions added to XPUB socket

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>

1 files changed, 6 insertions, 0 deletions

diff --git a/src/xpub.hpp b/src/xpub.hpp
index 13baf1f..2b63ec3 100644
--- a/src/xpub.hpp
+++ b/src/xpub.hpp
@@ -24,6 +24,7 @@
 #include "array.hpp"
 #include "pipe.hpp"
 #include "dist.hpp"
+#include "fq.hpp"
 
 namespace zmq
 {
@@ -40,6 +41,8 @@ namespace zmq
             const blob_t &peer_identity_);
         int xsend (zmq_msg_t *msg_, int flags_);
         bool xhas_out ();
+        int xrecv (zmq_msg_t *msg_, int flags_);
+        bool xhas_in ();
 
     private:
 
@@ -49,6 +52,9 @@ namespace zmq
         //  Distributor of messages holding the list of outbound pipes.
         dist_t dist;
 
+        //  Fair queuer for inbound subscriptions.
+        fq_t fq;
+
         xpub_t (const xpub_t&);
         const xpub_t &operator = (const xpub_t&);
     };