diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2012-04-13 09:34:13 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2012-04-14 05:21:09 +0200 |
commit | 19894e0a1b6fbbcb62028fc6513ef3904a6f5c76 (patch) | |
tree | 365270e76f29acca4d60f66773c3ec375e413a85 /src/options.hpp | |
parent | 4f120cb103db3987e01ece48648c844218b91ff2 (diff) |
Separate subscription forwarding from SUB-side filtering
- subscription forwarding is handled by XSUB socket
- filtering is handled by SUB sockets
- subscriptions are decoupled from filter engines
- filter doesn't have to be able to enumarate the subscriptions
(no sf_enumerate function)
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/options.hpp')
-rw-r--r-- | src/options.hpp | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/src/options.hpp b/src/options.hpp index 1288f72..fac6084 100644 --- a/src/options.hpp +++ b/src/options.hpp @@ -96,7 +96,7 @@ namespace xs int protocol; // Filter ID to be used with subscriptions and unsubscriptions. - int filter_id; + int filter; // If true, session reads all the pending messages from the pipe and // sends them to the network when socket is closed. @@ -106,9 +106,6 @@ namespace xs // them to the user when the peer terminates. bool delay_on_disconnect; - // If 1, (X)SUB socket should filter the messages. If 0, it should not. - bool filter; - // Sends identity to all new connections. bool send_identity; |