diff options
| author | Benoit Foucher <benoit@zeroc.com> | 2006-09-13 16:18:06 +0000 |
|---|---|---|
| committer | Benoit Foucher <benoit@zeroc.com> | 2006-09-13 16:18:06 +0000 |
| commit | e817166c5e13369f6cc8042f6530b1f3fac7c359 (patch) | |
| tree | 19691a2ca1e4c01faa3ae75fba840e50c6f70d06 /cpp/src/IceGrid/Topics.h | |
| parent | - Updating Ice and library verison to 3.2. (diff) | |
| download | ice-e817166c5e13369f6cc8042f6530b1f3fac7c359.tar.bz2 ice-e817166c5e13369f6cc8042f6530b1f3fac7c359.tar.xz ice-e817166c5e13369f6cc8042f6530b1f3fac7c359.zip | |
Simplified subscription code to use new per-subscriber publisher
Diffstat (limited to 'cpp/src/IceGrid/Topics.h')
| -rw-r--r-- | cpp/src/IceGrid/Topics.h | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/cpp/src/IceGrid/Topics.h b/cpp/src/IceGrid/Topics.h index c561dfa5862..3720d7f734c 100644 --- a/cpp/src/IceGrid/Topics.h +++ b/cpp/src/IceGrid/Topics.h @@ -29,18 +29,16 @@ public: virtual ~ObserverTopic(); void subscribe(const Ice::ObjectPrx&, const std::string& = std::string(), int = -1); - void subscribeAndWaitForSubscription(const Ice::ObjectPrx&, const std::string& = std::string()); void unsubscribe(const Ice::ObjectPrx&, const std::string& = std::string()); void destroy(); void receivedUpdate(const std::string&, int, const std::string&); - virtual void initObserver(const Ice::ObjectPrx&, const std::string&) = 0; + virtual void initObserver(const Ice::ObjectPrx&) = 0; protected: void waitForSyncedSubscribers(int); - void subscribeImpl(const Ice::ObjectPrx&, const std::string&); void updateSerial(int); Ice::Context getContext(int) const; @@ -64,7 +62,7 @@ public: void registryUp(const RegistryInfo&); void registryDown(const std::string&); - virtual void initObserver(const Ice::ObjectPrx&, const std::string&); + virtual void initObserver(const Ice::ObjectPrx&); private: @@ -88,7 +86,7 @@ public: const NodeObserverPrx& getPublisher() { return _externalPublisher; } void nodeDown(const std::string&); - virtual void initObserver(const Ice::ObjectPrx&, const std::string&); + virtual void initObserver(const Ice::ObjectPrx&); private: @@ -109,7 +107,7 @@ public: void applicationRemoved(int, const std::string&); void applicationUpdated(int, const ApplicationUpdateInfo&); - virtual void initObserver(const Ice::ObjectPrx&, const std::string&); + virtual void initObserver(const Ice::ObjectPrx&); private: @@ -129,7 +127,7 @@ public: void adapterUpdated(int, const AdapterInfo&); void adapterRemoved(int, const std::string&); - virtual void initObserver(const Ice::ObjectPrx&, const std::string&); + virtual void initObserver(const Ice::ObjectPrx&); private: @@ -149,7 +147,7 @@ public: void objectUpdated(int, const ObjectInfo&); void objectRemoved(int, const Ice::Identity&); - virtual void initObserver(const Ice::ObjectPrx&, const std::string&); + virtual void initObserver(const Ice::ObjectPrx&); private: |