class DeleteCyclicTaskProcessor implements NettyRemotingProcessor {
    private final CollectServer collectServer;

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

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

        TypeReference<List<Long>> typeReference = new TypeReference<>() {};
        List<Long> jobIds = JsonUtil.fromJson(message.getMsg(), typeReference);
        if (jobIds == null || jobIds.isEmpty()) {
            log.error("collector receive delete cyclic task job ids is null");
            return null;
        }
        for (Long jobId : jobIds) {
            collectServer.getCollectJobService().cancelAsyncCollectJob(jobId);   
        }
        return null;
    
<no_super_class>