diff options
| author | Mark Spruiell <mes@zeroc.com> | 2005-10-18 21:08:34 +0000 |
|---|---|---|
| committer | Mark Spruiell <mes@zeroc.com> | 2005-10-18 21:08:34 +0000 |
| commit | 88771d0b58199baf1a755ae580011413334ae96e (patch) | |
| tree | d464413084ea507ab99c0cd1f73503ab072d7eb0 /cpp/test/IceStorm/single/Subscriber.cpp | |
| parent | Fixed bug 518 (diff) | |
| download | ice-88771d0b58199baf1a755ae580011413334ae96e.tar.bz2 ice-88771d0b58199baf1a755ae580011413334ae96e.tar.xz ice-88771d0b58199baf1a755ae580011413334ae96e.zip | |
adding bi-directional tests
Diffstat (limited to 'cpp/test/IceStorm/single/Subscriber.cpp')
| -rw-r--r-- | cpp/test/IceStorm/single/Subscriber.cpp | 29 |
1 files changed, 29 insertions, 0 deletions
diff --git a/cpp/test/IceStorm/single/Subscriber.cpp b/cpp/test/IceStorm/single/Subscriber.cpp index fd53c2f722e..effd4246688 100644 --- a/cpp/test/IceStorm/single/Subscriber.cpp +++ b/cpp/test/IceStorm/single/Subscriber.cpp @@ -177,6 +177,35 @@ run(int argc, char* argv[], const CommunicatorPtr& communicator) topic->subscribe(qos, adapter->addWithUUID(subscribers.back())); } + // + // Setup bi-directional subscribers. + // + topic->ice_connection()->setAdapter(adapter); + { + subscribers.push_back(new SingleI(communicator, "bi-directional oneway")); + IceStorm::QoS qos; + qos["reliability"] = "oneway"; + topic->subscribeBidir(qos, adapter->addWithUUID(subscribers.back())->ice_getIdentity()); + } + { + subscribers.push_back(new SingleI(communicator, "bi-directional twoway")); + IceStorm::QoS qos; + qos["reliability"] = "twoway"; + topic->subscribeBidir(qos, adapter->addWithUUID(subscribers.back())->ice_getIdentity()); + } + { + subscribers.push_back(new SingleI(communicator, "bi-directional batch")); + IceStorm::QoS qos; + qos["reliability"] = "batch"; + topic->subscribeBidir(qos, adapter->addWithUUID(subscribers.back())->ice_getIdentity()); + } + { + subscribers.push_back(new SingleI(communicator, "bi-directional twoway ordered", true)); // Ordered + IceStorm::QoS qos; + qos["reliability"] = "twoway ordered"; + topic->subscribeBidir(qos, adapter->addWithUUID(subscribers.back())->ice_getIdentity()); + } + adapter->activate(); for(vector<SingleIPtr>::const_iterator p = subscribers.begin(); p != subscribers.end(); ++p) |