Added replicated IceStorm demo

1 files changed, 104 insertions, 0 deletions

diff --git a/cpp/demo/IceStorm/replicated/Publisher.cpp b/cpp/demo/IceStorm/replicated/Publisher.cpp
new file mode 100644
index 00000000000..187fd741909
--- /dev/null
+++ b/cpp/demo/IceStorm/replicated/Publisher.cpp
@@ -0,0 +1,104 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2006 ZeroC, Inc. All rights reserved.
+//
+// This copy of Ice is licensed to you under the terms described in the
+// ICE_LICENSE file included in this distribution.
+//
+// **********************************************************************
+
+#include <Ice/Application.h>
+#include <IceStorm/IceStorm.h>
+#include <IceGrid/Query.h>
+
+#include <Clock.h>
+
+using namespace std;
+using namespace Demo;
+
+class Publisher : public Ice::Application
+{
+public:
+
+    virtual int run(int, char*[]);
+};
+
+int
+main(int argc, char* argv[])
+{
+    Publisher app;
+    return app.main(argc, argv, "config.pub");
+}
+
+int
+Publisher::run(int argc, char* argv[])
+{
+    Ice::PropertiesPtr properties = communicator()->getProperties();
+
+    IceGrid::QueryPrx query = IceGrid::QueryPrx::uncheckedCast(communicator()->stringToProxy("DemoIceGrid/Query"));
+    Ice::ObjectProxySeq objects = query->findAllObjectsByType("::IceStorm::TopicManager");
+
+    string topicName = "time";
+    if(argc != 1)
+    {
+        topicName = argv[1];
+    }
+
+    Ice::ObjectPrx obj;
+    for(Ice::ObjectProxySeq::const_iterator p = objects.begin(); p != objects.end(); ++p)
+    {
+	IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::checkedCast(*p);
+	IceStorm::TopicPrx topic;
+	try
+	{
+	    topic = manager->create(topicName);
+	}
+	catch(const IceStorm::TopicExists&)
+	{
+	    try
+	    {
+	        topic = manager->retrieve(topicName);
+	    }
+	    catch(const IceStorm::TopicExists&)
+	    {
+	        cerr << appName() << ": temporary failure. try again." << endl;
+		return EXIT_FAILURE;
+	    }
+	}
+
+	if(!obj)
+	{
+	    //
+	    // Use per-request load balancing with round robin from the
+	    // IceGrid locator for the publisher object.
+	    //
+	    obj = topic->getPublisher()->ice_locatorCacheTimeout(0)->ice_connectionCached(false);
+	}
+    }
+
+    //
+    // Get the topic's publisher object, verify that it supports
+    // the Clock type, and create a oneway Clock proxy (for efficiency
+    // reasons). 
+    //
+    ClockPrx clock = ClockPrx::uncheckedCast(obj->ice_oneway());
+
+    try
+    {
+        while(true)
+        {
+            clock->tick(IceUtil::Time::now().toDateTime());
+#ifdef _WIN32
+            Sleep(1000);
+#else
+            sleep(1);
+#endif
+        }
+    }
+    catch(const Ice::CommunicatorDestroyedException&)
+    {
+        // Ignore
+    }
+
+    return EXIT_SUCCESS;
+}