cpp/demo/Ice/multicast/Server.cpp

   1 // **********************************************************************
   2 //
   3 // Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved.
   4 //
   5 // This copy of Ice is licensed to you under the terms described in the
   6 // ICE_LICENSE file included in this distribution.
   7 //
   8 // **********************************************************************
   9
  10 #include <Ice/Ice.h>
  11
  12 #include <Discovery.h>
  13 #include <Hello.h>
  14
  15 using namespace std;
  16 using namespace Demo;
  17
  18 class HelloI : public Hello
  19 {
  20 public:
  21
  22     virtual void
  23     sayHello(const Ice::Current&)
  24     {
  25         cout << "Hello World!" << endl;
  26     }
  27 };
  28
  29 class DiscoverI : public Discover
  30 {
  31 public:
  32
  33     DiscoverI(const Ice::ObjectPrx& obj) :
  34         _obj(obj)
  35     {
  36     }
  37
  38     virtual void
  39     lookup(const DiscoverReplyPrx& reply, const Ice::Current&)
  40     {
  41         try
  42         {
  43             reply->reply(_obj);
  44         }
  45         catch(const Ice::LocalException&)
  46         {
  47             // Ignore
  48         }
  49     }
  50
  51 private:
  52
  53     const Ice::ObjectPrx _obj;
  54 };
  55
  56 class HelloServer : public Ice::Application
  57 {
  58 public:
  59
  60     virtual int run(int, char*[]);
  61 };
  62
  63 int
  64 main(int argc, char* argv[])
  65 {
  66     HelloServer app;
  67     return app.main(argc, argv, "config.server");
  68 }
  69
  70 int
  71 HelloServer::run(int argc, char* argv[])
  72 {
  73     Ice::StringSeq args = Ice::argsToStringSeq(argc, argv);
  74     args = communicator()->getProperties()->parseCommandLineOptions("Discover", args);
  75
  76     Ice::ObjectAdapterPtr adapter = communicator()->createObjectAdapter("Hello");
  77     Ice::ObjectAdapterPtr discoverAdapter = communicator()->createObjectAdapter("Discover");
  78
  79     Ice::ObjectPrx hello = adapter->addWithUUID(new HelloI);
  80     DiscoverPtr d = new DiscoverI(hello);
  81     discoverAdapter->add(d, communicator()->stringToIdentity("discover"));
  82
  83     discoverAdapter->activate();
  84     adapter->activate();
  85
  86     communicator()->waitForShutdown();
  87     return EXIT_SUCCESS;
  88 }