//
// Created by dongl on 23-7-1.
//

#ifndef IM2_SYN_H
#define IM2_SYN_H

#include "message_safe/SafeQueue.h"

namespace MSG {
    class Syn : public db_base {
    public:
        explicit Syn(SafeQueue<SynMsg *> *mTimeLine);
        explicit Syn();
        virtual ~Syn();

    public:
        void push(SynMsg* msg);
        void syn_push_lister_queue(const std::function<void(std::string&& packet)>&);

    private:
        SafeQueue<SynMsg *>* m_timeLine = nullptr;
    };
}

#endif //IM2_SYN_H