diff options
| author | Mark Spruiell <mes@zeroc.com> | 2003-03-27 21:57:31 +0000 |
|---|---|---|
| committer | Mark Spruiell <mes@zeroc.com> | 2003-03-27 21:57:31 +0000 |
| commit | 88e0085253586777b27604bb057d9b495a3a5c09 (patch) | |
| tree | 8d0f422a88c8859dfaebbff3deb0fa90b8f0742a /cpp/test/IceStorm/single/Subscriber.cpp | |
| parent | assert fix (diff) | |
| download | ice-88e0085253586777b27604bb057d9b495a3a5c09.tar.bz2 ice-88e0085253586777b27604bb057d9b495a3a5c09.tar.xz ice-88e0085253586777b27604bb057d9b495a3a5c09.zip | |
cleaning up topic subscription; adding publish endpoints
Diffstat (limited to 'cpp/test/IceStorm/single/Subscriber.cpp')
| -rw-r--r-- | cpp/test/IceStorm/single/Subscriber.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/cpp/test/IceStorm/single/Subscriber.cpp b/cpp/test/IceStorm/single/Subscriber.cpp index ee9ee1a69e8..07f7d8e36df 100644 --- a/cpp/test/IceStorm/single/Subscriber.cpp +++ b/cpp/test/IceStorm/single/Subscriber.cpp @@ -102,13 +102,14 @@ run(int argc, char* argv[], const CommunicatorPtr& communicator) ObjectAdapterPtr adapter = communicator->createObjectAdapterWithEndpoints("SingleAdapter", "default"); ObjectPtr single = new SingleI(communicator); - ObjectPrx object = adapter->add(single, stringToIdentity("single/events")); + ObjectPrx object = adapter->addWithUUID(single); IceStorm::QoS qos; //TODO: qos["reliability"] = "batch"; try { - manager->subscribe(qos, object); + TopicPrx topic = manager->retrieve("single"); + topic->subscribe(qos, object); } catch(const IceStorm::NoSuchTopic& e) { |