1package org.apache.archiva.repository.scanner.functors;
23/*4 * Licensed to the Apache Software Foundation (ASF) under one5 * or more contributor license agreements. See the NOTICE file6 * distributed with this work for additional information7 * regarding copyright ownership. The ASF licenses this file8 * to you under the Apache License, Version 2.0 (the9 * "License"); you may not use this file except in compliance10 * with the License. You may obtain a copy of the License at11 *12 * http://www.apache.org/licenses/LICENSE-2.013 *14 * Unless required by applicable law or agreed to in writing,15 * software distributed under the License is distributed on an16 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY17 * KIND, either express or implied. See the License for the18 * specific language governing permissions and limitations19 * under the License.20 */2122import org.apache.archiva.consumers.RepositoryContentConsumer;
23import org.apache.archiva.repository.ManagedRepository;
24import org.apache.commons.collections4.Closure;
25import org.slf4j.Logger;
26import org.slf4j.LoggerFactory;
2728/**29 * TriggerScanCompletedClosure30 */31publicclassTriggerScanCompletedClosure32implements Closure<RepositoryContentConsumer>
33 {
34private Logger log = LoggerFactory.getLogger( TriggerScanCompletedClosure.class );
3536privatefinal ManagedRepository repository;
3738privateboolean executeOnEntireRepo = true;
3940publicTriggerScanCompletedClosure( ManagedRepository repository )
41 {
42this.repository = repository;
43 }
4445publicTriggerScanCompletedClosure( ManagedRepository repository, boolean executeOnEntireRepo )
46 {
47this( repository );
48this.executeOnEntireRepo = executeOnEntireRepo;
49 }
5051 @Override
52publicvoid execute( RepositoryContentConsumer input )
53 {
54 RepositoryContentConsumer consumer = (RepositoryContentConsumer) input;
55 consumer.completeScan( executeOnEntireRepo );
56 log.debug( "Consumer [{}] completed for repository [{}]", consumer.getId( ), repository.getId( ) );
57 }
58 }