summaryrefslogtreecommitdiff
path: root/cpp/test/IceStorm/single/Subscriber.cpp
diff options
context:
space:
mode:
authorMatthew Newhook <matthew@zeroc.com>2001-12-07 18:35:47 +0000
committerMatthew Newhook <matthew@zeroc.com>2001-12-07 18:35:47 +0000
commit19a8dd864e310db1a6097b48ae3fda4102ef9cea (patch)
treea17619ce7bc3ab4a07717b5e063ec1cd1bfd7c4a /cpp/test/IceStorm/single/Subscriber.cpp
parentfixes (diff)
downloadice-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.cpp15
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);
}