summaryrefslogtreecommitdiff
path: root/cpp/demo/IceStorm/clock/Subscriber.cpp
diff options
context:
space:
mode:
authorMatthew Newhook <matthew@zeroc.com>2001-11-27 14:24:58 +0000
committerMatthew Newhook <matthew@zeroc.com>2001-11-27 14:24:58 +0000
commited26a91d70fb1dece4208e013f67a7a2da84d748 (patch)
treeca04992186bb24b55866bc5e54d3bc112d9100ea /cpp/demo/IceStorm/clock/Subscriber.cpp
parentUpdated the SSL Connections to perform proper network tracing against (diff)
downloadice-ed26a91d70fb1dece4208e013f67a7a2da84d748.tar.bz2
ice-ed26a91d70fb1dece4208e013f67a7a2da84d748.tar.xz
ice-ed26a91d70fb1dece4208e013f67a7a2da84d748.zip
Update config file. Add README file. Small demo changes. Remove config file
from IceStorm src dir.
Diffstat (limited to 'cpp/demo/IceStorm/clock/Subscriber.cpp')
-rw-r--r--cpp/demo/IceStorm/clock/Subscriber.cpp19
1 files changed, 18 insertions, 1 deletions
diff --git a/cpp/demo/IceStorm/clock/Subscriber.cpp b/cpp/demo/IceStorm/clock/Subscriber.cpp
index 32158f9072b..02663318c28 100644
--- a/cpp/demo/IceStorm/clock/Subscriber.cpp
+++ b/cpp/demo/IceStorm/clock/Subscriber.cpp
@@ -41,11 +41,28 @@ run(int argc, char* argv[], const Ice::CommunicatorPtr& communicator)
Ice::ObjectPrx object = adapter->createProxy(id);
+ //
+ // The set of topics to which to subscribe
+ //
IceStorm::StringSeq topics;
topics.push_back("time");
+
+ //
+ // The requested quality of service. This requests "reliability" =
+ // "batch". This asks IceStorm to send events to the subscriber in
+ // batches at regular intervals.
+ //
IceStorm::QoS qos;
qos["reliability"] = "batch";
- manager->subscribe("events", qos, topics, object);
+ try
+ {
+ manager->subscribe("events", qos, topics, object);
+ }
+ catch(const IceStorm::NoSuchTopic& e)
+ {
+ cerr << argv[0] << ": NoSuchTopic: " << e.name << endl;
+ return EXIT_FAILURE;
+ }
adapter->activate();