diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-07-11 10:18:30 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-07-11 10:18:30 +0200 |
commit | c7542981d18b13b251d5a3129f1ec7ba24aeb9a1 (patch) | |
tree | 0557b82ed908ea48c68711587c1a76c487f8f45b /src/pgm_receiver.hpp | |
parent | d7adc3f19a4c941e854552d6d7881950a69b0d23 (diff) |
PGM transport reconciled with subscription forwarding
As PGM is not capable of passing subscriptions upstream,
subscriptions are ignored at sub side and engine subscribes
for all messages on pub side.
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/pgm_receiver.hpp')
-rw-r--r-- | src/pgm_receiver.hpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/pgm_receiver.hpp b/src/pgm_receiver.hpp index 825e0c1..aa010dd 100644 --- a/src/pgm_receiver.hpp +++ b/src/pgm_receiver.hpp @@ -64,6 +64,10 @@ namespace zmq private: + // PGM is not able to move subscriptions upstream. Thus, drop all + // the pending subscriptions. + void drop_subscriptions (); + // RX timeout timer ID. enum {rx_timer_id = 0xa1}; |