NotificationConsumer.h

// $Id: NotificationConsumer.h,v 1.13 2013/01/08 05:07:32 abeard Exp $

#ifndef NOTIFICATIONCONSUMER_H
#define NOTIFICATIONCONSUMER_H

#include <orbsvcs/CosNotifyChannelAdminC.h>
#include <orbsvcs/CosNotifyCommS.h>

namespace carma {
   namespace util {

     class Orb;

      class NotificationConsumer : 
        virtual public POA_CosNotifyComm::StructuredPushConsumer
        {
          
        public:

          NotificationConsumer(Orb* localOrb,
                               const std::string channelName, 
                               const std::string consumerName);

          ~NotificationConsumer();
          
          // IDL to C++ mapping

          virtual void push_structured_event(const CosNotification::StructuredEvent &event) 
            throw(CosEventComm::Disconnected, CORBA::SystemException);
          
          virtual void disconnect_structured_push_consumer() 
            throw(CORBA::SystemException);
          
          virtual void offer_change(const CosNotification::EventTypeSeq&,
                                    const CosNotification::EventTypeSeq&)
            throw(CosNotifyComm::InvalidEventType, CORBA::SystemException);

          virtual PortableServer::POA_ptr _default_POA();
          
          virtual void run();
          
          bool isActive();

          void deactivateConsumer();

        protected:

          Orb* localOrb_;
          std::string localOrbName_;

          CORBA::ORB_var orb_;    // The ORB.
          PortableServer::POA_var poa_;    // My POA.
          CosNotifyChannelAdmin::StructuredProxyPushSupplier_var proxyPushSupplier_;
          const std::string channelName_;
          const std::string consumerName_;

          void setProxyPushSupplier ();

        private:

          void activatePoa();

          bool isActive_;

        }; // End class NotificationConsumer

   } // End namespace util
} // End namespace carma

#endif // eventconsumer_h