class XPluginImp implements Plugin {
    CloudEventServiceRocketmqImp eventService;

    @Override
    public void start(AppContext context) {<FILL_FUNCTION_BODY>}

    @Override
    public void prestop() throws Throwable {
        if (eventService != null) {
            eventService.close();
        }
    }
}

        CloudProps cloudProps = new CloudProps(context, "rocketmq");

        if (Utils.isEmpty(cloudProps.getEventServer())) {
            return;
        }

        if (cloudProps.getEventEnable()) {
            eventService = new CloudEventServiceRocketmqImp(cloudProps);
            CloudManager.register(eventService);

            context.lifecycle(-99, () -> eventService.subscribe());
        }
    
<no_super_class>