#include "DataConsumer.h"
#include <QMutex>
#include <QSemaphore>
#include <QThread>
#include <QDateTime>
#include <QQueue>
#include <QVariant>
#include "LibraryLoader.h"
#include "Client.h"
DataConsumer::DataConsumer()
{

}

DataConsumer::~DataConsumer()
{

}



/*void DataConsumer::run()
{
    while(!isInterruptionRequested()){

    }
}*/

void DataConsumer::Setup(ConsumerInfo &ci)
{
    std::string assemblyName = ci.AssemblyName;
    std::string className = ci.ClassName;

    BaseModule* pModule = nullptr;// = (BaseModule)Assembly.LoadFile(Path.GetFullPath(@".\" + assemblyName)).CreateInstance(className);
    pModule = LibraryLoader::load<BaseModule>(assemblyName);
    if( pModule == nullptr )
    {
        //        qCritical() << LOG_HEADER << " load " << szPlugin.c_str() << " failed.";
        return;
    }
    if( pModule == nullptr )
    {

        qCritical() << __FILE__ << __LINE__ << " " << assemblyName.c_str() << " load failed.";
        return;
    }

    {
        //Client*
        runable = dynamic_cast<Client*>(pModule);
        runable->Run();
    }
}

std::string DataConsumer::getTypeList()
{
    return "DataStorage::RunnableModule";
}

void DataConsumer::setLoader(QLibrary *)
{

}

/*void DataConsumer::regConsumer(DataConsumer *dc)
{
    dataConsumer = dc;
}*/

/*void DataConsumer::Run()
{
    //start();
}*/

void DataConsumer::OnData(QString user, QString key, QVariant val)
{
    runable->OnData(user, key, val);
}