diff --git a/src/pPowerManger/udpcomm/udpComm.cpp b/src/pPowerManger/udpcomm/udpComm.cpp
index e5e13a0..f269b24 100644
--- a/src/pPowerManger/udpcomm/udpComm.cpp
+++ b/src/pPowerManger/udpcomm/udpComm.cpp
@@ -178,6 +178,7 @@ bool udpComm::pushMsgToQueue(unsigned char *m)
       if(m_qReceiveCcuStateBuffer.size()<QUENUE_SIZE)
       {
         double time = MOOSTime(false);
+        std::lock_guard<std::mutex> lock(m_mutexCcuState);
         m_qReceiveCcuStateBuffer.push(std::make_pair(time, s));
       }
       else
@@ -201,6 +202,7 @@ bool udpComm::pushMsgToQueue(unsigned char *m)
       if(m_qReceiveCcuSetParmBuffer.size()<QUENUE_SIZE)
       {
         double time = MOOSTime(false);
+        std::lock_guard<std::mutex> lock(m_mutexCcuSetParm);
         m_qReceiveCcuSetParmBuffer.push(std::make_pair(time, s));
       }
       else
@@ -224,6 +226,7 @@ bool udpComm::pushMsgToQueue(unsigned char *m)
       if(m_qReceiveDisHighVolBusBuffer.size()<QUENUE_SIZE)
       {
         double time = MOOSTime(false);
+        std::lock_guard<std::mutex> lock(m_mutexDisHighVolBus);
         m_qReceiveDisHighVolBusBuffer.push(std::make_pair(time, s));
       }
       else 
@@ -247,6 +250,7 @@ bool udpComm::pushMsgToQueue(unsigned char *m)
       if(m_qReceiveDisHighAVolBusBuffer.size()<QUENUE_SIZE)
         {
           double time = MOOSTime(false);
+          std::lock_guard<std::mutex> lock(m_mutexDisHighAVolBus);
           m_qReceiveDisHighAVolBusBuffer.push(std::make_pair(time, s));
         }
       else
@@ -270,6 +274,7 @@ bool udpComm::pushMsgToQueue(unsigned char *m)
       if(m_qReceiveDisHighBVolBusBuffer.size()<QUENUE_SIZE)
       {
           double time = MOOSTime(false);
+          std::lock_guard<std::mutex> lock(m_mutexDisHighBVolBus);
           m_qReceiveDisHighBVolBusBuffer.push(std::make_pair(time, s));
       }
       else
@@ -293,6 +298,7 @@ bool udpComm::pushMsgToQueue(unsigned char *m)
       if(m_qReceiveDisLowBusBuffer.size()<QUENUE_SIZE)
        {
           double time = MOOSTime(false);
+          std::lock_guard<std::mutex> lock(m_mutexDisLowBus);
           m_qReceiveDisLowBusBuffer.push(std::make_pair(time, s));
        }
       else