class RuleLogHandler {

    @Autowired
    private ElasticSearchService elasticSearchService;

    @Subscribe("/rule-engine/*/*/event/${rule.engine.event.level:error}")
    public Mono<Void> handleEvent(TopicPayload event) {
        return elasticSearchService.commit(RuleEngineLoggerIndexProvider.RULE_EVENT_LOG, RuleEngineExecuteEventInfo.of(event));
    }

    @Subscribe("/rule-engine/*/*/logger/${rule.engine.logging.level:info,warn,error}")
    public Mono<Void> handleLog(LogEvent event) {<FILL_FUNCTION_BODY>}
}

        JSONObject jsonObject = FastBeanCopier.copy(event, new JSONObject());
        jsonObject.put("createTime", System.currentTimeMillis());
        return elasticSearchService.commit(RuleEngineLoggerIndexProvider.RULE_LOG, jsonObject);
    
<no_super_class>