1 files changed, 151 insertions, 0 deletions
diff --git a/cpp/demo/IceStorm/replicated2/Publisher.cpp b/cpp/demo/IceStorm/replicated2/Publisher.cpp
new file mode 100644
index 00000000000..36fbf10b0f6
--- /dev/null
+++ b/cpp/demo/IceStorm/replicated2/Publisher.cpp
@@ -0,0 +1,151 @@
+// **********************************************************************
+//
+// Copyright (c) 2003-2008 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 <IceUtil/IceUtil.h>
+#include <Ice/Ice.h>
+#include <IceStorm/IceStorm.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");
+}
+
+void
+usage(const string& n)
+{
+    cerr << "Usage: " << n << " [--datagram|--twoway|--oneway] [topic]" << endl;
+}
+
+int
+Publisher::run(int argc, char* argv[])
+{
+    enum Option { None, Datagram, Twoway, Oneway };
+    Option option = None;
+    string topicName = "time";
+    int i;
+
+    for(i = 1; i < argc; ++i)
+    {
+        string optionString = argv[i];
+        Option oldoption = option;
+        if(optionString == "--datagram")
+        {
+            option = Datagram;
+        }
+        else if(optionString == "--twoway")
+        {
+            option = Twoway;
+        }
+        else if(optionString == "--oneway")
+        {
+            option = Oneway;
+        }
+        else if(optionString.substr(0, 2) == "--")
+        {
+            usage(argv[0]);
+            return EXIT_FAILURE;
+        }
+        else
+        {
+            topicName = argv[i++];
+            break;
+        }
+
+        if(oldoption != option && oldoption != None)
+        {
+            usage(argv[0]);
+            return EXIT_FAILURE;
+        }
+    }
+
+    if(i != argc)
+    {
+        usage(argv[0]);
+        return EXIT_FAILURE;
+    }
+
+    IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::checkedCast(
+        communicator()->propertyToProxy("TopicManager.Proxy"));
+    if(!manager)
+    {
+        cerr << appName() << ": invalid proxy" << endl;
+        return EXIT_FAILURE;
+    }
+
+    //
+    // Retrieve the topic.
+    //
+    IceStorm::TopicPrx topic;
+    try
+    {
+        topic = manager->retrieve(topicName);
+    }
+    catch(const IceStorm::NoSuchTopic&)
+    {
+        try
+        {
+            topic = manager->create(topicName);
+        }
+        catch(const IceStorm::TopicExists&)
+        {
+            cerr << appName() << ": temporary failure. try again." << endl;
+            return EXIT_FAILURE;
+        }
+    }
+
+    //
+    // Get the topic's publisher object, and create a Clock proxy with
+    // the mode specified as an argument of this application.
+    //
+    Ice::ObjectPrx publisher = topic->getPublisher();
+    if(option == Datagram)
+    {
+        publisher = publisher->ice_datagram();
+    }
+    else if(option == Twoway)
+    {
+        // Do nothing.
+    }
+    else if(option == Oneway || option == None)
+    {
+        publisher = publisher->ice_oneway();
+    }
+    
+    ClockPrx clock = ClockPrx::uncheckedCast(publisher);
+
+    cout << "publishing tick events. Press ^C to terminate the application." << endl;
+    try
+    {
+        while(true)
+        {
+            clock->tick(IceUtil::Time::now().toDateTime());
+            IceUtil::ThreadControl::sleep(IceUtil::Time::seconds(1));
+        }
+    }
+    catch(const Ice::CommunicatorDestroyedException&)
+    {
+        // Ignore
+    }
+
+    return EXIT_SUCCESS;
+}