class CollectCyclicDataProcessor implements NettyRemotingProcessor {
    private final CollectServer collectServer;

    public CollectCyclicDataProcessor(CollectServer collectServer) {
        this.collectServer = collectServer;
    }

    @Override
    public ClusterMsg.Message handle(ChannelHandlerContext ctx, ClusterMsg.Message message) {<FILL_FUNCTION_BODY>}
}

        Job job = JsonUtil.fromJson(message.getMsg(), Job.class);
        if (job == null) {
            log.error("collector receive cyclic task job is null");
            return null;
        }
        collectServer.getCollectJobService().addAsyncCollectJob(job);
        return null;
    
<no_super_class>