1package org.apache.archiva.indexer;
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.repository.RepositoryType;
23import org.apache.archiva.repository.UnsupportedRepositoryTypeException;
24import org.springframework.context.ApplicationContext;
25import org.springframework.stereotype.Service;
2627import javax.inject.Inject;
28import java.util.HashMap;
29import java.util.Map;
3031/**32 * This factory is used to get a index manager for a certain repository type.33 */34 @Service("indexerManagerFactory")
35publicclassIndexManagerFactory {
3637 Map<RepositoryType, ArchivaIndexManager> managers= new HashMap<>();
3839 @Inject
40 ApplicationContext applicationContext;
4142publicArchivaIndexManager getIndexManager(RepositoryType type) {
43if (managers.containsKey(type)) {
44return managers.get(type);
45 } else {
46ArchivaIndexManager manager = applicationContext.getBeansOfType(ArchivaIndexManager.class).values().stream().
47 filter(m -> m.supportsRepository(type)).
48 findFirst().orElseThrow(() -> newUnsupportedRepositoryTypeException(type));
49 managers.put(type, manager);
50return manager;
51 }
52 }
53 }