class CanalListener implements RocketMQListener<String> {

    private static final Logger log = LoggerFactory.getLogger(CanalListener.class);

    @Autowired
    private CanalGlue canalGlue;
    @Override
    public void onMessage(String message) {<FILL_FUNCTION_BODY>}
}

        Map map = JSON.parseObject(message, Map.class);
        String table = map.get("table").toString();
        String database = map.get("database").toString();
        log.info("canal-database: {}, table: {}, mq message:{}", database, table, message);
        canalGlue.process(message);
    
<no_super_class>