'Handles incoming messages
@overrides SoftwareSwitch.rx_message'

def rx_message(self, connection, msg):

    self.connection_in_action = connection
    if (not self.check_rights(msg, connection)):
        self.log.warn('Message    %s    not    allowed    for    slave    controller    %d', msg, connection.ID)
        self.send_vendor_error(connection)
    else:
        SoftwareSwitch.rx_message(self, connection, msg)
    self.connection_in_action = None
