summaryrefslogtreecommitdiff
path: root/cpp/test/IceStorm/single/Subscriber.cpp
diff options
context:
space:
mode:
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 40fec79d20a..23f3ca1db29 100644
--- a/cpp/test/IceStorm/single/Subscriber.cpp
+++ b/cpp/test/IceStorm/single/Subscriber.cpp
@@ -79,23 +79,24 @@ run(int argc, char* argv[], const CommunicatorPtr& communicator)
}
createLock(lockfile);
- const char* managerReferenceProperty = "IceStorm.TopicManager";
- string managerReference = properties->getProperty(managerReferenceProperty);
- if(managerReference.empty())
+ const char* managerProxyProperty = "IceStorm.TopicManager.Proxy";
+ string managerProxy = properties->getProperty(managerProxyProperty);
+ if(managerProxy.empty())
{
- cerr << argv[0] << ": property `" << managerReferenceProperty << "' is not set" << endl;
+ cerr << argv[0] << ": property `" << managerProxyProperty << "' is not set" << endl;
return EXIT_FAILURE;
}
- ObjectPrx base = communicator->stringToProxy(managerReference);
+ ObjectPrx base = communicator->stringToProxy(managerProxy);
IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::checkedCast(base);
if(!manager)
{
- cerr << argv[0] << ": `" << managerReference << "' is not running" << endl;
+ cerr << argv[0] << ": `" << managerProxy << "' is not running" << endl;
return EXIT_FAILURE;
}
- ObjectAdapterPtr adapter = communicator->createObjectAdapterWithEndpoints("SingleAdapter", "default");
+ properties->setProperty("SingleAdapter", "default");
+ ObjectAdapterPtr adapter = communicator->createObjectAdapter("SingleAdapter");
ObjectPtr single = new SingleI(communicator);
ObjectPrx object = adapter->add(single, stringToIdentity("single/events"));