zmq_encoder/decoder are able to add/trim prefixes from messages; fair queueing and load balancing algorithms factorised into separate classes

1 files changed, 7 insertions, 1 deletions

diff --git a/src/xreq.hpp b/src/xreq.hpp
index 8d6a3b2..fdf8b0f 100644
--- a/src/xreq.hpp
+++ b/src/xreq.hpp
@@ -21,7 +21,8 @@
 #define __ZMQ_XREQ_HPP_INCLUDED__
 
 #include "socket_base.hpp"
-#include "yarray.hpp"
+#include "fq.hpp"
+#include "lb.hpp"
 
 namespace zmq
 {
@@ -48,6 +49,11 @@ namespace zmq
 
     private:
 
+        //  Messages are fair-queued from inbound pipes. And load-balanced to
+        //  the outbound pipes.
+        fq_t fq;
+        lb_t lb;
+
         xreq_t (const xreq_t&);
         void operator = (const xreq_t&);
     };