001/** 002 * Licensed to the Apache Software Foundation (ASF) under one or more 003 * contributor license agreements. See the NOTICE file distributed with 004 * this work for additional information regarding copyright ownership. 005 * The ASF licenses this file to You under the Apache License, Version 2.0 006 * (the "License"); you may not use this file except in compliance with 007 * the License. You may obtain a copy of the License at 008 * 009 * http://www.apache.org/licenses/LICENSE-2.0 010 * 011 * Unless required by applicable law or agreed to in writing, software 012 * distributed under the License is distributed on an "AS IS" BASIS, 013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 014 * See the License for the specific language governing permissions and 015 * limitations under the License. 016 */ 017package org.apache.camel.blueprint; 018 019import java.util.List; 020import java.util.Map; 021import java.util.Map.Entry; 022 023import org.apache.camel.RoutesBuilder; 024import org.apache.camel.spi.PackageScanFilter; 025import org.osgi.service.blueprint.container.BlueprintContainer; 026import org.slf4j.Logger; 027import org.slf4j.LoggerFactory; 028 029/** 030 * A helper class which will find all {@link org.apache.camel.builder.RouteBuilder} instances in the 031 * {@link org.osgi.service.blueprint.container.BlueprintContainer}. 032 * 033 * @version 034 */ 035public class ContextScanRouteBuilderFinder { 036 private static final Logger LOG = LoggerFactory.getLogger(ContextScanRouteBuilderFinder.class); 037 private final BlueprintContainer blueprintContainer; 038 private final PackageScanFilter filter; 039 private final boolean includeNonSingletons; 040 041 public ContextScanRouteBuilderFinder(BlueprintCamelContext camelContext, PackageScanFilter filter, boolean includeNonSingletons) { 042 this.blueprintContainer = camelContext.getBlueprintContainer(); 043 this.filter = filter; 044 this.includeNonSingletons = includeNonSingletons; 045 } 046 047 /** 048 * Appends all the {@link org.apache.camel.builder.RouteBuilder} instances that can be found in the context 049 */ 050 public void appendBuilders(List<RoutesBuilder> list) { 051 Map<String, RoutesBuilder> beans = BlueprintContainerRegistry.lookupByType(blueprintContainer, RoutesBuilder.class, includeNonSingletons); 052 053 for (Entry<String, RoutesBuilder> entry : beans.entrySet()) { 054 String key = entry.getKey(); 055 Object bean = entry.getValue(); 056 057 LOG.trace("Found RouteBuilder with id: {} -> {}", key, bean); 058 059 // certain beans should be ignored 060 if (shouldIgnoreBean(bean)) { 061 LOG.debug("Ignoring RouteBuilder id: {}", key); 062 continue; 063 } 064 065 if (!isFilteredClass(bean)) { 066 if (LOG.isDebugEnabled()) { 067 LOG.debug("Ignoring filtered RouteBuilder id: {} as class: {}", key, bean.getClass()); 068 } 069 continue; 070 } 071 072 if (LOG.isDebugEnabled()) { 073 LOG.debug("Adding instantiated RouteBuilder id: {} as class: {}", key, bean.getClass()); 074 } 075 list.add((RoutesBuilder) bean); 076 } 077 } 078 079 protected boolean shouldIgnoreBean(Object bean) { 080 return false; 081 } 082 083 protected boolean isFilteredClass(Object bean) { 084 if (filter != null) { 085 return filter.matches(bean.getClass()); 086 } else { 087 return false; 088 } 089 } 090 091}