diff options
Diffstat (limited to 'cpp/demo/IceStorm/clock/Subscriber.cpp')
| -rw-r--r-- | cpp/demo/IceStorm/clock/Subscriber.cpp | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/cpp/demo/IceStorm/clock/Subscriber.cpp b/cpp/demo/IceStorm/clock/Subscriber.cpp index ff7dae7b886..7861052760d 100644 --- a/cpp/demo/IceStorm/clock/Subscriber.cpp +++ b/cpp/demo/IceStorm/clock/Subscriber.cpp @@ -154,7 +154,14 @@ Subscriber::run(int argc, char* argv[]) try { IceStorm::TopicPrx topic = manager->retrieve(q->first); - topic->unsubscribe(q->second); + if(bidir) + { + topic->unsubscribeBidir(q->second->ice_getIdentity()); + } + else + { + topic->unsubscribe(q->second); + } } catch(const IceStorm::NoSuchTopic& e) { |