You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2010/06/05 09:49:57 UTC
svn commit: r951668 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/impl/osgi/Activator.java
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;