diff options
| author | Dwayne Boone <dwayne@zeroc.com> | 2005-10-19 15:43:10 +0000 |
|---|---|---|
| committer | Dwayne Boone <dwayne@zeroc.com> | 2005-10-19 15:43:10 +0000 |
| commit | 19a1416abf94dffc6a502efc5f7dd8077ee00504 (patch) | |
| tree | bc1f9b788bb358b4f54dedc732149d08f7eb8c89 /cpp/test/IceStorm/single/Subscriber.cpp | |
| parent | Fix (diff) | |
| download | ice-19a1416abf94dffc6a502efc5f7dd8077ee00504.tar.bz2 ice-19a1416abf94dffc6a502efc5f7dd8077ee00504.tar.xz ice-19a1416abf94dffc6a502efc5f7dd8077ee00504.zip | |
Remove IceStorm bidir support
Diffstat (limited to 'cpp/test/IceStorm/single/Subscriber.cpp')
| -rw-r--r-- | cpp/test/IceStorm/single/Subscriber.cpp | 29 |
1 files changed, 0 insertions, 29 deletions
diff --git a/cpp/test/IceStorm/single/Subscriber.cpp b/cpp/test/IceStorm/single/Subscriber.cpp index effd4246688..fd53c2f722e 100644 --- a/cpp/test/IceStorm/single/Subscriber.cpp +++ b/cpp/test/IceStorm/single/Subscriber.cpp @@ -177,35 +177,6 @@ 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) |