'Handle an incoming OpenFlow message'

def rx_message(self, connection, msg):

    ofp_type = msg.header_type
    h = self.ofp_handlers.get(ofp_type)
    if (h is None):
        raise RuntimeError(('No    handler    for    ofp_type    %s(%d)' % (ofp_type_map.get(ofp_type), ofp_type)))
    self.log.debug('Got    %s    with    XID    %s', ofp_type_map.get(ofp_type), msg.xid)
    h(msg, connection=connection)
