'Raises events when a complete message is available.
Subclasses may want to call this when they have a new message
available.  See _recv_raw().'

def _rx_message(self, msg):

    e = self.raiseEventNoErrors(MessageReceived, self, msg.get('CHANNEL'), msg)
    self._transport._nexus._rx_message(self, msg)
