diff options
| author | Dwayne Boone <dwayne@zeroc.com> | 2006-11-07 13:30:07 +0000 |
|---|---|---|
| committer | Dwayne Boone <dwayne@zeroc.com> | 2006-11-07 13:30:07 +0000 |
| commit | db55fb00e84f8d62f51ad0e84a7ec74df01e2d69 (patch) | |
| tree | 8a71bde0b16a5bd3924e1573655e554180e9f0a8 /cpp/src/IceGrid/AdminSessionI.cpp | |
| parent | Fixed a few coding style issues. (diff) | |
| download | ice-db55fb00e84f8d62f51ad0e84a7ec74df01e2d69.tar.bz2 ice-db55fb00e84f8d62f51ad0e84a7ec74df01e2d69.tar.xz ice-db55fb00e84f8d62f51ad0e84a7ec74df01e2d69.zip | |
Added FixedProxyException
Diffstat (limited to 'cpp/src/IceGrid/AdminSessionI.cpp')
| -rw-r--r-- | cpp/src/IceGrid/AdminSessionI.cpp | 17 |
1 files changed, 11 insertions, 6 deletions
diff --git a/cpp/src/IceGrid/AdminSessionI.cpp b/cpp/src/IceGrid/AdminSessionI.cpp index cfe57adc0db..e1b31d4e98f 100644 --- a/cpp/src/IceGrid/AdminSessionI.cpp +++ b/cpp/src/IceGrid/AdminSessionI.cpp @@ -58,11 +58,16 @@ AdminSessionI::setObservers(const RegistryObserverPrx& registryObserver, throw ex; } - setupObserverSubscription(RegistryObserverTopicName, registryObserver); - setupObserverSubscription(NodeObserverTopicName, nodeObserver); - setupObserverSubscription(ApplicationObserverTopicName, appObserver); - setupObserverSubscription(AdapterObserverTopicName, adapterObserver); - setupObserverSubscription(ObjectObserverTopicName, objectObserver); + setupObserverSubscription(RegistryObserverTopicName, + registryObserver ? registryObserver->ice_timeout(_timeout * 1000) : 0); + setupObserverSubscription(NodeObserverTopicName, + nodeObserver ? nodeObserver->ice_timeout(_timeout * 1000) : 0); + setupObserverSubscription(ApplicationObserverTopicName, + appObserver ? appObserver->ice_timeout(_timeout * 1000) : 0); + setupObserverSubscription(AdapterObserverTopicName, + adapterObserver ? adapterObserver->ice_timeout(_timeout * 1000) : 0); + setupObserverSubscription(ObjectObserverTopicName, + objectObserver ? objectObserver->ice_timeout(_timeout * 1000) : 0); } void @@ -286,7 +291,7 @@ AdminSessionI::setupObserverSubscription(TopicName name, const Ice::ObjectPrx& o if(observer) { - _observers[name] = observer->ice_timeout(_timeout * 1000); + _observers[name] = observer; _database->getObserverTopic(name)->subscribe(_observers[name]); } } |