diff options
Diffstat (limited to 'cpp/test/IceStorm/stress/Subscriber.cpp')
-rw-r--r-- | cpp/test/IceStorm/stress/Subscriber.cpp | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/cpp/test/IceStorm/stress/Subscriber.cpp b/cpp/test/IceStorm/stress/Subscriber.cpp index 01590e4702f..50b49962fab 100644 --- a/cpp/test/IceStorm/stress/Subscriber.cpp +++ b/cpp/test/IceStorm/stress/Subscriber.cpp @@ -334,11 +334,17 @@ run(int argc, char* argv[], const CommunicatorPtr& communicator) { p->obj = p->obj->ice_oneway(); } - p->adapter->activate(); topic->subscribeAndGetPublisher(qos, p->obj); } } + { + for(vector<Subscription>::iterator p = subs.begin(); p != subs.end(); ++p) + { + p->adapter->activate(); + } + } + communicator->waitForShutdown(); { |