diff options
Diffstat (limited to 'cpp/src/IceGrid/Topics.h')
| -rw-r--r-- | cpp/src/IceGrid/Topics.h | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/cpp/src/IceGrid/Topics.h b/cpp/src/IceGrid/Topics.h index f8fc0312c44..56554537ce9 100644 --- a/cpp/src/IceGrid/Topics.h +++ b/cpp/src/IceGrid/Topics.h @@ -28,7 +28,7 @@ public: ObserverTopic(const IceStorm::TopicManagerPrx&, const std::string&); virtual ~ObserverTopic(); - void subscribe(const Ice::ObjectPrx&, const std::string& = std::string(), int = -1); + void subscribe(const Ice::ObjectPrx&, const std::string& = std::string()); void unsubscribe(const Ice::ObjectPrx&, const std::string& = std::string()); void destroy(); @@ -38,14 +38,13 @@ public: protected: - void waitForSyncedSubscribers(int); + void waitForSyncedSubscribers(int, const std::string& = std::string()); void updateSerial(int); Ice::Context getContext(int) const; Ice::LoggerPtr _logger; IceStorm::TopicPrx _topic; Ice::ObjectPrx _basePublisher; - std::set<Ice::Identity> _waitForSubscribe; int _serial; std::set<std::string> _syncSubscribers; @@ -148,6 +147,9 @@ public: void objectUpdated(int, const ObjectInfo&); void objectRemoved(int, const Ice::Identity&); + void objectsAddedOrUpdated(int, const ObjectInfoSeq&); + void objectsRemoved(int, const ObjectInfoSeq&); + virtual void initObserver(const Ice::ObjectPrx&); private: |