//
// Created by dongl on 23-5-29.
//

#ifndef IM2_STORAGE_H
#define IM2_STORAGE_H


#include "message_base/db_base.h"
#include "message_safe/SafeQueue.h"

namespace MSG {
    class Storage : db_base {
    public:
        Storage(SafeQueue<StorageMsg *> *timeLine, db_base* db);
        Storage(std::string&&  db_name, std::string&& table);

        virtual ~Storage();

    public:
        void push(StorageMsg* msg);

        void storage_push_lister_queue();

    private:
        SafeQueue<StorageMsg *> * m_timeLine = nullptr;

        std::string m_db_name, m_table;
    };
}

#endif //IM2_STORAGE_H