lp-data-store/DataManagerMain/DataSubscribe.h

#ifndef DATASUBSCRIBE_H
#define DATASUBSCRIBE_H
#include "../include/RunnableModule.h"

#include <QtCore/QThread>
#include "DataConsumer.h"
#include "Define.h"

#include <QDateTime>

class DataSubscribe : public RunnableModule, public QThread
{
public:
    DataSubscribe();
    virtual void Setup(ModuleInfo& mi);

    virtual std::string getTypeList();

    virtual void regConsumer(DataConsumer* dc) ;
    virtual void Run() ;

private:
    virtual void run();
    virtual void setLoader(QLibrary*);
private:
    QLibrary* library = nullptr;
    DataConsumer* dataConsumer = nullptr;
    std::string dataName;
    ModuleInfo mi;
    SharedData shares;

};

#endif // DATASUBSCRIBE_H