svn commit: r951668 - /camel/trunk/camel-core/src/main/java/org/apache/camel/impl/osgi/Activator.java

[davsclaus]

Author: davsclaus
Date: Sat Jun  5 07:49:57 2010
New Revision: 951668

URL: http://svn.apache.org/viewvc?rev=951668&view=rev
Log:
CAMEL-2693, CAMEL-2792: OSGi improvements. Fixed a DEBUG log being wrong. Fixed 
CS.

Modified:
    
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/osgi/Activator.java

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/osgi/Activator.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/osgi/Activator.java?rev=951668&r1=951667&r2=951668&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/osgi/Activator.java 
(original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/osgi/Activator.java 
Sat Jun  5 07:49:57 2010
@@ -101,11 +101,11 @@ public class Activator implements Bundle
     public void removedBundle(Bundle bundle, BundleEvent event, Object object) 
{
         if (LOG.isDebugEnabled()) {
             LOG.debug("Bundle stopped: " + bundle.getSymbolicName());
-            List<BaseService> r = resolvers.remove(bundle.getBundleId());
-            if (r != null) {
-                for (BaseService service : r) {
-                    service.unregister();
-                }
+        }
+        List<BaseService> r = resolvers.remove(bundle.getBundleId());
+        if (r != null) {
+            for (BaseService service : r) {
+                service.unregister();
             }
         }
     }
@@ -275,9 +275,12 @@ public class Activator implements Bundle
         }
 
         class Loader extends AnnotationTypeConverterLoader {
+
             Loader() {
                 super(null);
             }
+
+            @SuppressWarnings("unchecked")
             public void load(TypeConverterRegistry registry) throws Exception {
                 PackageScanFilter test = new 
AnnotatedWithPackageScanFilter(Converter.class, true);
                 Set<Class<?>> classes = new LinkedHashSet<Class<?>>();
@@ -317,7 +320,7 @@ public class Activator implements Bundle
 
     }
 
-    protected static abstract class BaseResolver<T> extends BaseService {
+    protected abstract static class BaseResolver<T> extends BaseService {
 
         private final Class<T> type;
 
@@ -337,6 +340,7 @@ public class Activator implements Bundle
             return createInstance(name, url, context.getInjector());
         }
 
+        @SuppressWarnings("unchecked")
         protected T createInstance(String name, URL url, Injector injector) {
             try {
                 Properties properties = loadProperties(url);
@@ -353,7 +357,7 @@ public class Activator implements Bundle
 
     }
 
-    protected static abstract class BaseService {
+    protected abstract static class BaseService {
 
         protected final Bundle bundle;
         private ServiceRegistration reg;
@@ -396,12 +400,7 @@ public class Activator implements Bundle
         } catch (IOException e) {
             throw new RuntimeException(e);
         } finally {
-            try {
-                if (reader != null) {
-                    reader.close();
-                }
-            } catch (Exception ignore) {
-            }
+            IOHelper.close(reader, "properties", LOG);
         }
         return properties;
     }
@@ -444,9 +443,7 @@ public class Activator implements Bundle
             } catch (Exception ignore) {
                 // Do nothing here
             } finally {
-                if (reader != null) {
-                    IOHelper.close(reader, null, LOG);
-                }
+                IOHelper.close(reader, null, LOG);
             }
         }
         return packages;