summaryrefslogtreecommitdiff
path: root/cpp/demo/IceStorm/replicated/Subscriber.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/demo/IceStorm/replicated/Subscriber.cpp')
-rw-r--r--cpp/demo/IceStorm/replicated/Subscriber.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/cpp/demo/IceStorm/replicated/Subscriber.cpp b/cpp/demo/IceStorm/replicated/Subscriber.cpp
index 130254bba64..6cf37097cbd 100644
--- a/cpp/demo/IceStorm/replicated/Subscriber.cpp
+++ b/cpp/demo/IceStorm/replicated/Subscriber.cpp
@@ -193,6 +193,11 @@ Subscriber::run(int argc, char* argv[])
}
Ice::ObjectPrx subscriber = adapter->add(new ClockI, subId);
+ //
+ // Activate the object adapter before subscribing.
+ //
+ adapter->activate();
+
IceStorm::QoS qos;
if(!retryCount.empty())
{
@@ -247,7 +252,6 @@ Subscriber::run(int argc, char* argv[])
}
cout << "reactivating persistent subscriber" << endl;
}
- adapter->activate();
shutdownOnInterrupt();
communicator()->waitForShutdown();