DAMessageQueueProxy.h

#ifndef DAMESSAGEQUEUEPROXY_H
#define DAMESSAGEQUEUEPROXY_H
#include "DAMessageHandlerGlobal.h"
#include "DAMessageLogItem.h"
#include <QObject>
namespace DA
{
 
class DAMESSAGEHANDLER_API DAMessageQueueProxy : public QObject
{
    Q_OBJECT
    DA_DECLARE_PRIVATE(DAMessageQueueProxy)
    friend class DAThreadSafeMessageQueue_Private;
 
public:
    DAMessageQueueProxy(QObject* par = nullptr);
    ~DAMessageQueueProxy();
    //设置信号发射间隔
    void setEmitInterval(int ms);
    int getEmitInterval() const;
 
    //插入一个日志内容
    void append(const DAMessageLogItem& item);
 
    //消息内容
    DAMessageLogItem at(int index) const;
 
    //尺寸
    int size() const;
 
    //设置惰性触发
    void setLazyEmit(bool on = true);
    bool isLazyEmit() const;
 
    //清空队列
    void clear();
 
    //设置全局队列的容量
    static void setGlobalQueueCapacity(int c);
 
    //获取全局队列的尺寸
    static int getGlobalQueueCapacity();
private slots:
    void onTimeout();
signals:
    void messageQueueAppended();
    void messageQueueSizeChanged(int newSize);
 
protected:
    void emitSignal(int type);
};
}  // namespace DA
#endif  // DAGLOBALLOGQUEUE_H