summaryrefslogtreecommitdiff
path: root/cpp/test/IceStorm/stress/Subscriber.cpp
diff options
context:
space:
mode:
authorMatthew Newhook <matthew@zeroc.com>2007-02-02 05:00:22 +0000
committerMatthew Newhook <matthew@zeroc.com>2007-02-02 05:00:22 +0000
commit0d9d5dfe240ff74ccbbc19e3d47a8b079dca06a0 (patch)
tree13638ca1f856eb41a2a745cc2287740a1bb562df /cpp/test/IceStorm/stress/Subscriber.cpp
parenthttp://bugzilla.zeroc.com/bugzilla/show_bug.cgi?id=1738 (diff)
downloadice-0d9d5dfe240ff74ccbbc19e3d47a8b079dca06a0.tar.bz2
ice-0d9d5dfe240ff74ccbbc19e3d47a8b079dca06a0.tar.xz
ice-0d9d5dfe240ff74ccbbc19e3d47a8b079dca06a0.zip
http://bugzilla.zeroc.com/bugzilla/show_bug.cgi?id=1739
Diffstat (limited to 'cpp/test/IceStorm/stress/Subscriber.cpp')
-rw-r--r--cpp/test/IceStorm/stress/Subscriber.cpp8
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();
{