transporterSignalProcessor.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2007 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: transporterSignalProcessor.h,v $ $Revision: 1.1 $ $State: Exp $
*******************************************************************************/



#ifndef DtVrfTransporterSignalProcessor_H
#define DtVrfTransporterSignalProcessor_H

#include "vrfMsgTransport/signalMessageProcessor.h"

#include "vrfMsgTransport/signalMessageTransporter.h"
#include "vrfMsgTransport/externalCommsMessageTransporter.h"

#include <boost/signal.hpp>

class DtVrfSignalMessageParams;

class DT_DLL_vrfMsgTransport DtVrfTransporterSignalProcessor : public DtVrfSignalMessageProcessor
{
private:

   DtVrfTransporterSignalProcessor(const DtVrfTransporterSignalProcessor& orig);
   DtVrfTransporterSignalProcessor& operator=(const DtVrfTransporterSignalProcessor& orig);

protected:

   DtVrfTransporterSignalProcessor(const char* pName);

   virtual bool init();

public:

   virtual ~DtVrfTransporterSignalProcessor();

   virtual void installSelf(DtRadioMessageListener& rml);
   virtual void setEnabled(bool bIsEnabled);

   boost::signal<void (const DtVrfSignalMessageParams*, DtVrfObjectMessageConstPtr&)> signal_CommsFxMessageReceived;

   boost::signal<void (const DtVrfSignalMessageParams*, DtVrfObjectMessageConstPtr&)> signal_RadioMessageReceived;

public: 

   static DtVrfSignalMessageProcessor* create(const char* pName);

protected:

   static void newSignalMessageCallback(DtSignalMessageTransporterCallbackParams* pTransporterParams, void* usr);
   virtual void processNewSignalMessage(DtSignalMessageTransporterCallbackParams* pTransporterParams);

   static void newQualnetMessageCallback(const DtExternalCommsMessageTransporter::DtExternalCommsMessageCallbackParams& transporterParams, void* usr);
   virtual void processNewQualnetMessage(const DtExternalCommsMessageTransporter::DtExternalCommsMessageCallbackParams& transporterParams);

protected:

   DtExternalCommsMessageTransporter* pMyExternalCommsMessageTransporter;

   DtSignalMessageTransporter* pMySignalTransporter;

};

#endif