Source code

001package org.apache.archiva.indexer.merger;
002/*
003 * Licensed to the Apache Software Foundation (ASF) under one
004 * or more contributor license agreements.  See the NOTICE file
005 * distributed with this work for additional information
006 * regarding copyright ownership.  The ASF licenses this file
007 * to you under the Apache License, Version 2.0 (the
008 * "License"); you may not use this file except in compliance
009 * with the License.  You may obtain a copy of the License at
010 *
011 *   http://www.apache.org/licenses/LICENSE-2.0
012 *
013 * Unless required by applicable law or agreed to in writing,
014 * software distributed under the License is distributed on an
015 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
016 * KIND, either express or implied.  See the License for the
017 * specific language governing permissions and limitations
018 * under the License.
019 */
020
021import org.apache.archiva.common.plexusbridge.PlexusSisuBridge;
022import org.apache.archiva.common.plexusbridge.PlexusSisuBridgeException;
023import org.apache.maven.index.NexusIndexer;
024import org.slf4j.Logger;
025import org.slf4j.LoggerFactory;
026import org.springframework.scheduling.annotation.Scheduled;
027import org.springframework.stereotype.Service;
028
029import javax.inject.Inject;
030import java.util.Date;
031
032/**
033 * @author Olivier Lamy
034 * @since 1.4-M2
035 */
036@Service
037public class TemporaryGroupIndexCleaner
038{
039    private Logger log = LoggerFactory.getLogger( getClass() );
040
041    @Inject
042    private IndexMerger indexMerger;
043
044    private NexusIndexer indexer;
045
046    @Inject
047    public TemporaryGroupIndexCleaner( PlexusSisuBridge plexusSisuBridge )
048        throws PlexusSisuBridgeException
049    {
050        indexer = plexusSisuBridge.lookup( NexusIndexer.class );
051    }
052
053    // 900000
054    @Scheduled(fixedDelay = 900000)
055    public void cleanTemporaryIndex()
056    {
057
058        for ( TemporaryGroupIndex temporaryGroupIndex : indexMerger.getTemporaryGroupIndexes() )
059        {
060            // cleanup files older than the ttl
061            if ( new Date().getTime() - temporaryGroupIndex.getCreationTime() > temporaryGroupIndex.getMergedIndexTtl() )
062            {
063                log.info( "cleanTemporaryIndex for groupId {}", temporaryGroupIndex.getGroupId() );
064                indexMerger.cleanTemporaryGroupIndex( temporaryGroupIndex );
065
066            }
067        }
068    }
069}