DDSHelper.h

Go to the documentation of this file.

#ifndef _DDS_HELPER_H_
#define _DDS_HELPER_H_

#include <iostream>
#include <string.h>
#include <loggingACEMACROS.h>
#include <dds/DCPS/Service_Participant.h>
#include <dds/DCPS/Marked_Default_Qos.h>

const unsigned int DOMAIN_ID=411;

namespace ddsnc{

        class DDSHelper{
                private:
                void setTopicName(const char* topicName);
                void init(const char* channelName, const char* DCPSInfoRepoLoc);
                /*int argc;
                const ACE_TCHAR* argv[];*/

                protected:
                DDS::DomainParticipantFactory_ptr dpf;
                DDS::DomainParticipant_var participant;
                DDS::Topic_var topic;
                char* partitionName;
                char* topicName;
                bool initialized; 
                DDSHelper(CORBA::String_var channelName);

                DDSHelper(const char* channelName, const char* DCPSInfoRepoLoc);                
                
                virtual ~DDSHelper();
                int createParticipant();

                void initializeTopic(const char* topicName, CORBA::String_var typeName);
                
                void initializeTopic(CORBA::String_var typeName);
                
                void setPartitionName(const char* partitionName);
                
                public:
                void disconnect();
                DDS::TopicQos topicQos;

                static void cleanUp();
                CORBA::String_var getChannelName();

        };
}

#endif