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