//--------------------------------------------------------------------------------------------
class CMQMgr
{
public:
//nProcMethod = 0;
CMQMgr(int nMsgLen, int nMaxQueueNum, int nProcMethod=0);
~CMQMgr();
void Push(unsigned char* byRecData, int nDataLen);
void InsertHead(unsigned char* byRecData, int nDataLen);
int Pop(unsigned char* byProcData);
int GetQueueCount();
void SetMaxCount(int nMax = -1, bool bDrop = false);
int GetMaxCount();
void SetNotifyEvt(pthread_cond_t* hNotifyEvent){m_hNotifyEvt = hNotifyEvent;}