summaryrefslogtreecommitdiff
path: root/cpp/src/IceGrid/AdminSessionI.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/IceGrid/AdminSessionI.cpp')
-rw-r--r--cpp/src/IceGrid/AdminSessionI.cpp54
1 files changed, 44 insertions, 10 deletions
diff --git a/cpp/src/IceGrid/AdminSessionI.cpp b/cpp/src/IceGrid/AdminSessionI.cpp
index bdf87d55c6a..de31ff90996 100644
--- a/cpp/src/IceGrid/AdminSessionI.cpp
+++ b/cpp/src/IceGrid/AdminSessionI.cpp
@@ -58,16 +58,50 @@ AdminSessionI::setObservers(const RegistryObserverPrx& registryObserver,
throw ex;
}
- setupObserverSubscription(RegistryObserverTopicName,
- registryObserver ? registryObserver->ice_timeout(_timeout * 1000) : Ice::ObjectPrx());
- setupObserverSubscription(NodeObserverTopicName,
- nodeObserver ? nodeObserver->ice_timeout(_timeout * 1000) : Ice::ObjectPrx());
- setupObserverSubscription(ApplicationObserverTopicName,
- appObserver ? appObserver->ice_timeout(_timeout * 1000) : Ice::ObjectPrx());
- setupObserverSubscription(AdapterObserverTopicName,
- adapterObserver ? adapterObserver->ice_timeout(_timeout * 1000) : Ice::ObjectPrx());
- setupObserverSubscription(ObjectObserverTopicName,
- objectObserver ? objectObserver->ice_timeout(_timeout * 1000) : Ice::ObjectPrx());
+ if(registryObserver)
+ {
+ setupObserverSubscription(RegistryObserverTopicName, registryObserver->ice_timeout(_timeout * 1000));
+ }
+ else
+ {
+ setupObserverSubscription(RegistryObserverTopicName, Ice::ObjectPrx());
+ }
+
+ if(nodeObserver)
+ {
+ setupObserverSubscription(NodeObserverTopicName, nodeObserver->ice_timeout(_timeout * 1000));
+ }
+ else
+ {
+ setupObserverSubscription(NodeObserverTopicName, Ice::ObjectPrx());
+ }
+
+ if(appObserver)
+ {
+ setupObserverSubscription(ApplicationObserverTopicName, appObserver->ice_timeout(_timeout * 1000));
+ }
+ else
+ {
+ setupObserverSubscription(ApplicationObserverTopicName, Ice::ObjectPrx());
+ }
+
+ if(adapterObserver)
+ {
+ setupObserverSubscription(AdapterObserverTopicName, adapterObserver->ice_timeout(_timeout * 1000));
+ }
+ else
+ {
+ setupObserverSubscription(AdapterObserverTopicName, Ice::ObjectPrx());
+ }
+
+ if(objectObserver)
+ {
+ setupObserverSubscription(ObjectObserverTopicName, objectObserver->ice_timeout(_timeout * 1000));
+ }
+ else
+ {
+ setupObserverSubscription(ObjectObserverTopicName, Ice::ObjectPrx());
+ }
}
void