diff options
author | Matthew Newhook <matthew@zeroc.com> | 2001-12-07 18:35:47 +0000 |
---|---|---|
committer | Matthew Newhook <matthew@zeroc.com> | 2001-12-07 18:35:47 +0000 |
commit | 19a8dd864e310db1a6097b48ae3fda4102ef9cea (patch) | |
tree | a17619ce7bc3ab4a07717b5e063ec1cd1bfd7c4a /cpp/test/IceStorm/single/Subscriber.cpp | |
parent | fixes (diff) | |
download | ice-19a8dd864e310db1a6097b48ae3fda4102ef9cea.tar.bz2 ice-19a8dd864e310db1a6097b48ae3fda4102ef9cea.tar.xz ice-19a8dd864e310db1a6097b48ae3fda4102ef9cea.zip |
IceStorm updates.
Diffstat (limited to 'cpp/test/IceStorm/single/Subscriber.cpp')
-rw-r--r-- | cpp/test/IceStorm/single/Subscriber.cpp | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/cpp/test/IceStorm/single/Subscriber.cpp b/cpp/test/IceStorm/single/Subscriber.cpp index 9c6538f2430..c8986d5d372 100644 --- a/cpp/test/IceStorm/single/Subscriber.cpp +++ b/cpp/test/IceStorm/single/Subscriber.cpp @@ -73,20 +73,20 @@ run(int argc, char* argv[], const Ice::CommunicatorPtr& communicator) } createLock(lockfile); - Ice::PropertiesPtr properties = communicator->getProperties(); - const char* refProperty = "IceStorm.TopicManager"; - std::string ref = properties->getProperty(refProperty); - if (ref.empty()) + PropertiesPtr properties = communicator->getProperties(); + const char* managerEndpointsProperty = "IceStorm.TopicManager.Endpoints"; + string managerEndpoints = properties->getProperty(managerEndpointsProperty); + if (managerEndpoints.empty()) { - cerr << argv[0] << ": property `" << refProperty << "' not set" << endl; + cerr << argv[0] << ": " << managerEndpointsProperty << " is not set" << endl; return EXIT_FAILURE; } - Ice::ObjectPrx base = communicator->stringToProxy(ref); + ObjectPrx base = communicator->stringToProxy("TopicManager:" + managerEndpoints); IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::checkedCast(base); if (!manager) { - cerr << argv[0] << ": invalid object reference" << endl; + cerr << argv[0] << ": `" << managerEndpoints << "' is not running" << endl; return EXIT_FAILURE; } @@ -129,6 +129,7 @@ main(int argc, char* argv[]) try { + addArgumentPrefix("IceStorm"); communicator = Ice::initialize(argc, argv); status = run(argc, argv, communicator); } |