Author: bvahdat
Date: Sat Oct 27 10:23:30 2012
New Revision: 1402779
URL: http://svn.apache.org/viewvc?rev=1402779&view=rev
Log:
CAMEL-5745: Fixed the broken build after the upgrade to OSGi 4.3.0.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/impl/osgi/Activator.java
camel/trunk/components/camel-core-osgi/src/main/java/org/apache/camel/core/osgi/OsgiCamelContextPublisher.java
camel/trunk/components/camel-core-osgi/src/test/java/org/apache/camel/core/osgi/CamelMockBundle.java
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/Activator.java
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminConsumer.java
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminProducer.java
camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/Activator.java
camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.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=1402779&r1=1402778&r2=1402779&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 Oct 27 10:23:30 2012
@@ -291,7 +291,6 @@ public class Activator implements Bundle
super(null);
}
- @SuppressWarnings("unchecked")
public void load(TypeConverterRegistry registry) throws
TypeConverterLoaderException {
PackageScanFilter test = new
AnnotatedWithPackageScanFilter(Converter.class, true);
Set<Class<?>> classes = new LinkedHashSet<Class<?>>();
@@ -396,11 +395,11 @@ public class Activator implements Bundle
try {
Properties properties = loadProperties(url);
String classname = (String) properties.get("class");
- Class<T> type = bundle.loadClass(classname);
+ Class<?> type = bundle.loadClass(classname);
if (!this.type.isAssignableFrom(type)) {
throw new IllegalArgumentException("Type is not a " +
this.type.getName() + " implementation. Found: " + type.getName());
}
- return injector.newInstance(type);
+ return injector.newInstance((Class<T>) type);
} catch (ClassNotFoundException e) {
throw new IllegalArgumentException("Invalid URI, no " +
this.type.getName() + " registered for scheme : " + name, e);
}
@@ -411,7 +410,7 @@ public class Activator implements Bundle
protected abstract static class BaseService {
protected final Bundle bundle;
- private ServiceRegistration reg;
+ private ServiceRegistration<?> reg;
protected BaseService(Bundle bundle) {
this.bundle = bundle;
@@ -433,7 +432,7 @@ public class Activator implements Bundle
doRegister(type, null);
}
- protected void doRegister(Class<?> type, Dictionary<?, ?> props) {
+ protected void doRegister(Class<?> type, Dictionary<String, ?> props) {
reg = bundle.getBundleContext().registerService(type.getName(),
this, props);
}
Modified:
camel/trunk/components/camel-core-osgi/src/main/java/org/apache/camel/core/osgi/OsgiCamelContextPublisher.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-core-osgi/src/main/java/org/apache/camel/core/osgi/OsgiCamelContextPublisher.java?rev=1402779&r1=1402778&r2=1402779&view=diff
==============================================================================
---
camel/trunk/components/camel-core-osgi/src/main/java/org/apache/camel/core/osgi/OsgiCamelContextPublisher.java
(original)
+++
camel/trunk/components/camel-core-osgi/src/main/java/org/apache/camel/core/osgi/OsgiCamelContextPublisher.java
Sat Oct 27 10:23:30 2012
@@ -18,8 +18,8 @@ package org.apache.camel.core.osgi;
import java.util.Dictionary;
import java.util.EventObject;
+import java.util.Hashtable;
import java.util.Map;
-import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;
import org.apache.camel.CamelContext;
@@ -43,7 +43,7 @@ public class OsgiCamelContextPublisher e
public static final String CONTEXT_NAME_PROPERTY = "camel.context.name";
private final BundleContext bundleContext;
- private final Map<CamelContext, ServiceRegistration> registrations = new
ConcurrentHashMap<CamelContext, ServiceRegistration>();
+ private final Map<CamelContext, ServiceRegistration<?>> registrations =
new ConcurrentHashMap<CamelContext, ServiceRegistration<?>>();
public OsgiCamelContextPublisher(BundleContext bundleContext) {
this.bundleContext = bundleContext;
@@ -53,18 +53,18 @@ public class OsgiCamelContextPublisher e
if (event instanceof CamelContextStartedEvent) {
CamelContext context = ((CamelContextStartedEvent)
event).getContext();
- Properties props = new Properties();
+ Dictionary<String, Object > props = new Hashtable<String,
Object>();
props.put(CONTEXT_SYMBOLIC_NAME_PROPERTY,
bundleContext.getBundle().getSymbolicName());
props.put(CONTEXT_VERSION_PROPERTY,
getBundleVersion(bundleContext.getBundle()));
props.put(CONTEXT_NAME_PROPERTY, context.getName());
log.debug("Registering CamelContext [{}] of in OSGi registry",
props);
- ServiceRegistration reg =
bundleContext.registerService(CamelContext.class.getName(), context, props);
+ ServiceRegistration<?> reg =
bundleContext.registerService(CamelContext.class.getName(), context, props);
registrations.put(context, reg);
} else if (event instanceof CamelContextStoppingEvent) {
CamelContext context = ((CamelContextStoppingEvent)
event).getContext();
- ServiceRegistration reg = registrations.get(context);
+ ServiceRegistration<?> reg = registrations.get(context);
if (reg != null) {
if (log.isDebugEnabled()) {
log.debug("Unregistering CamelContext [{}] from OSGi
registry", context.getName());
Modified:
camel/trunk/components/camel-core-osgi/src/test/java/org/apache/camel/core/osgi/CamelMockBundle.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-core-osgi/src/test/java/org/apache/camel/core/osgi/CamelMockBundle.java?rev=1402779&r1=1402778&r2=1402779&view=diff
==============================================================================
---
camel/trunk/components/camel-core-osgi/src/test/java/org/apache/camel/core/osgi/CamelMockBundle.java
(original)
+++
camel/trunk/components/camel-core-osgi/src/test/java/org/apache/camel/core/osgi/CamelMockBundle.java
Sat Oct 27 10:23:30 2012
@@ -17,6 +17,7 @@
package org.apache.camel.core.osgi;
import java.net.URL;
+import java.security.cert.X509Certificate;
import java.util.ArrayList;
import java.util.Enumeration;
import java.util.List;
@@ -103,7 +104,7 @@ public class CamelMockBundle extends Moc
}
@Override
- public Map<?, ?> getSignerCertificates(int signersType) {
+ public Map<X509Certificate, List<X509Certificate>>
getSignerCertificates(int signersType) {
return null;
}
Modified:
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/Activator.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/Activator.java?rev=1402779&r1=1402778&r2=1402779&view=diff
==============================================================================
---
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/Activator.java
(original)
+++
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/Activator.java
Sat Oct 27 10:23:30 2012
@@ -16,7 +16,8 @@
*/
package org.apache.camel.component.eventadmin;
-import java.util.Properties;
+import java.util.Dictionary;
+import java.util.Hashtable;
import org.apache.camel.spi.ComponentResolver;
import org.osgi.framework.BundleActivator;
@@ -29,10 +30,10 @@ import org.osgi.framework.ServiceRegistr
*/
public class Activator implements BundleActivator {
- private ServiceRegistration registration;
+ private ServiceRegistration<?> registration;
public void start(BundleContext bundleContext) throws Exception {
- Properties props = new Properties();
+ Dictionary<String, String> props = new Hashtable<String, String>();
props.put("component", EventAdminComponent.NAME);
registration = bundleContext.registerService(
ComponentResolver.class.getName(),
Modified:
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminConsumer.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminConsumer.java?rev=1402779&r1=1402778&r2=1402779&view=diff
==============================================================================
---
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminConsumer.java
(original)
+++
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminConsumer.java
Sat Oct 27 10:23:30 2012
@@ -16,7 +16,8 @@
*/
package org.apache.camel.component.eventadmin;
-import java.util.Properties;
+import java.util.Dictionary;
+import java.util.Hashtable;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.impl.DefaultConsumer;
@@ -31,7 +32,7 @@ public class EventAdminConsumer extends
private static final transient Logger LOG =
LoggerFactory.getLogger(EventAdminConsumer.class);
private final EventAdminEndpoint endpoint;
- private ServiceRegistration registration;
+ private ServiceRegistration<?> registration;
public EventAdminConsumer(EventAdminEndpoint endpoint, Processor
processor) {
@@ -59,7 +60,7 @@ public class EventAdminConsumer extends
@Override
protected void doStart() throws Exception {
super.doStart();
- Properties props = new Properties();
+ Dictionary<String, String> props = new Hashtable<String, String>();
props.put(EventConstants.EVENT_TOPIC, endpoint.getTopic());
registration =
endpoint.getComponent().getBundleContext().registerService(EventHandler.class.getName(),
this, props);
}
Modified:
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminProducer.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminProducer.java?rev=1402779&r1=1402778&r2=1402779&view=diff
==============================================================================
---
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminProducer.java
(original)
+++
camel/trunk/components/camel-eventadmin/src/main/java/org/apache/camel/component/eventadmin/EventAdminProducer.java
Sat Oct 27 10:23:30 2012
@@ -89,13 +89,13 @@ public class EventAdminProducer extends
Event event = context.getTypeConverter().convertTo(Event.class,
exchange, in.getBody());
if (event == null) {
String topic = getTopic(exchange);
- Dictionary<?, ?> props = getProperties(exchange);
+ Dictionary<String, ?> props = getProperties(exchange);
event = new Event(topic, props);
}
return event;
}
- protected Dictionary<?, ?> getProperties(Exchange exchange) {
+ protected Dictionary<String, ?> getProperties(Exchange exchange) {
Message in = exchange.getIn();
CamelContext context = endpoint.getCamelContext();
Map<?, ?> map = context.getTypeConverter().convertTo(Map.class,
exchange, in.getBody());
Modified:
camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/Activator.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/Activator.java?rev=1402779&r1=1402778&r2=1402779&view=diff
==============================================================================
---
camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/Activator.java
(original)
+++
camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/Activator.java
Sat Oct 27 10:23:30 2012
@@ -16,7 +16,8 @@
*/
package org.apache.camel.component.paxlogging;
-import java.util.Properties;
+import java.util.Dictionary;
+import java.util.Hashtable;
import org.apache.camel.spi.ComponentResolver;
import org.osgi.framework.BundleActivator;
@@ -28,10 +29,10 @@ import org.osgi.framework.ServiceRegistr
*/
public class Activator implements BundleActivator {
- private ServiceRegistration registration;
+ private ServiceRegistration<?> registration;
public void start(BundleContext bundleContext) throws Exception {
- Properties props = new Properties();
+ Dictionary<String, String> props = new Hashtable<String, String>();
props.put("component", PaxLoggingComponent.NAME);
registration = bundleContext.registerService(
ComponentResolver.class.getName(),
Modified:
camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.java?rev=1402779&r1=1402778&r2=1402779&view=diff
==============================================================================
---
camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.java
(original)
+++
camel/trunk/components/camel-paxlogging/src/main/java/org/apache/camel/component/paxlogging/PaxLoggingConsumer.java
Sat Oct 27 10:23:30 2012
@@ -16,7 +16,8 @@
*/
package org.apache.camel.component.paxlogging;
-import java.util.Properties;
+import java.util.Dictionary;
+import java.util.Hashtable;
import java.util.concurrent.ExecutorService;
import org.apache.camel.Exchange;
@@ -44,7 +45,7 @@ public class PaxLoggingConsumer extends
private static final transient Logger LOG =
LoggerFactory.getLogger(PaxLoggingConsumer.class);
private final PaxLoggingEndpoint endpoint;
private ExecutorService executor;
- private ServiceRegistration registration;
+ private ServiceRegistration<?> registration;
public PaxLoggingConsumer(PaxLoggingEndpoint endpoint, Processor
processor) {
super(endpoint, processor);
@@ -86,7 +87,7 @@ public class PaxLoggingConsumer extends
@Override
protected void doStart() throws Exception {
super.doStart();
- Properties props = new Properties();
+ Dictionary<String, String> props = new Hashtable<String, String>();
props.put("org.ops4j.pax.logging.appender.name", endpoint.getName());
registration =
endpoint.getComponent().getBundleContext().registerService(PaxAppender.class.getName(),
this, props);
executor =
endpoint.getCamelContext().getExecutorServiceManager().newSingleThreadExecutor(this,
"PaxLoggingEventTask");
