summaryrefslogtreecommitdiff
path: root/cpp/test/IceStorm/single/Subscriber.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2002-09-11 20:33:06 +0000
committerBenoit Foucher <benoit@zeroc.com>2002-09-11 20:33:06 +0000
commitaf019e080ac9319035abe899838bc6ff7bf7e435 (patch)
tree754643a46a0f0ef381b0a7596fc08a17dcda5cdf /cpp/test/IceStorm/single/Subscriber.cpp
parentFix bug in changeTimeout (the newEndpoints were not passed to the (diff)
downloadice-af019e080ac9319035abe899838bc6ff7bf7e435.tar.bz2
ice-af019e080ac9319035abe899838bc6ff7bf7e435.tar.xz
ice-af019e080ac9319035abe899838bc6ff7bf7e435.zip
Object adapter creation method changes, IceBox changes.
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"));