subscriber.h

Go to the documentation of this file.

#ifndef SUBSCRIBER_H_
#define SUBSCRIBER_H_

#include <iostream>
#include <string.h>
#include <boost/function.hpp>
#include <boost/bind.hpp>
#include "ccpp_dds_dcps.h"
#include "check_status.h"
#include "ccpp_GSDFPacket.h"
#include "example_main.h"
#include "GSDFPacket_listener.h"

using namespace DDS;

namespace opensplice_dds_broker{
    class Subscriber
    {
        public:
            Subscriber(const std::string& topic_name);
            void subscribe(void (*callBack)(const GSDFPacket& packet));
            void subscribe(boost::function<void(const GSDFPacket&)> callBack);
            ~Subscriber();
        private:
            DomainId_t  domain;
            ReturnCode_t  status;
            const char *topic_name_;
            char  *GSDFPacketTypeName;
            
            //Generic DDS entities
            DomainParticipantFactory_var  dpf;
            DomainParticipant_var  participant;
            Topic_var  GSDFPacketTopic;
            Subscriber_var  subscriber_;
            DataReader_ptr  parentReader;

            GSDFPacketTypeSupport_var  GSDFPacketTS;
            GSDFPacketDataReader_var  GSDFPacketDR;

            //QosPolicy holders
            TopicQos  topic_qos;
            SubscriberQos  sub_qos;
            DataReaderQos  dr_qos;
    };
};

#endif