#ifndef __SQLSYNCDELAYTHREAD_H
#define __SQLSYNCDELAYTHREAD_H

#include "Policies/SingletonImp.h"
#include "ace/Thread_Mutex.h"
#include "ace/Activation_Queue.h"
#include "Threading.h"

class Database;
class SqlOperation;

class SqlSyncDelayThread : public ACE_Based::Runnable
{
    typedef ACE_Activation_Queue SqlQueue;

    private:
        SqlQueue m_sqlQueue;                                ///< Queue of SQL statements
        Database* m_dbEngine;                               ///< Pointer to used Database engine
        volatile bool m_running;

    public:
        SqlSyncDelayThread(){};

        ///< Put sql statement to delay queue
        bool Delay(SqlOperation* sql, Database* db);

        void Stop();                                ///< Stop event
        virtual void run();                                 ///< Main Thread loop
};
#define sSyncDelayThread Trinity::Singleton<SqlSyncDelayThread*>::Instance()
#endif