''

def processMsg(self):

    while (len(self.buffer_) > 0):
        msgID = struct.unpack('=H', self.buffer_[:2])[0]
        assert (msgID in self.msgProcesser_), ('unknown    message    id    %s' % msgID)
        msgLength = (struct.unpack('=H', self.buffer_[2:4])[0] + 4)
        if (len(self.buffer_) < msgLength):
            return
        stream = MessageStream.MessageStreamReader(self.buffer_[4:msgLength])
        self.buffer_ = self.buffer_[msgLength:]
        self.msgProcesser_[msgID](stream)
