aFunlang/include/core/msg.inline.h

#ifndef AFUN_MSG_INLINE_H
#define AFUN_MSG_INLINE_H
#include "msg.h"

namespace aFuncore {
    inline Message::Message(const std::string &type_) : type {type_}, next {nullptr} {

    }

    inline TopMessage::TopMessage(const std::string &type_) : Message(type_) {

    }

    inline NormalMessage::NormalMessage(Object *obj_) : TopMessage("NORMAL"), obj {obj_} {

    }

    inline Object *NormalMessage::getObject() {
        return obj;
    }

    inline std::string ErrorMessage::getErrorType() {
        return error_type;
    }

    inline std::string ErrorMessage::getErrorInfo() {
        return error_info;
    }

    inline InterMessage::InterMessage() : MessageStream() {  // NOLINT mutex通过pthread_mutex_init初始化
        pthread_mutex_init(&mutex, nullptr);
    }

    inline InterMessage::~InterMessage(){
        pthread_mutex_destroy(&mutex);
    }
}

#endif //AFUN_MSG_INLINE_H