diff options
author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-15 09:09:19 +0100 |
---|---|---|
committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-15 09:09:19 +0100 |
commit | e49115224a7957b0e5d49326bc02ae6af186eaf9 (patch) | |
tree | 81d1ca0ea496004bbc85cec9b3289af96cdaa197 /src/zmq_encoder.hpp | |
parent | bd792faa9d6c78c375dbc52c6d773e157335da36 (diff) |
zmq_encoder/decoder are able to add/trim prefixes from messages; fair queueing and load balancing algorithms factorised into separate classes
Diffstat (limited to 'src/zmq_encoder.hpp')
-rw-r--r-- | src/zmq_encoder.hpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/zmq_encoder.hpp b/src/zmq_encoder.hpp index 825e60f..8d4e956 100644 --- a/src/zmq_encoder.hpp +++ b/src/zmq_encoder.hpp @@ -32,7 +32,7 @@ namespace zmq { public: - zmq_encoder_t (size_t bufsize_); + zmq_encoder_t (size_t bufsize_, bool trim_prefix_); ~zmq_encoder_t (); void set_inout (struct i_inout *source_); @@ -46,6 +46,8 @@ namespace zmq ::zmq_msg_t in_progress; unsigned char tmpbuf [9]; + bool trim_prefix; + zmq_encoder_t (const zmq_encoder_t&); void operator = (const zmq_encoder_t&); }; |