Author: davsclaus
Date: Mon Oct 29 16:50:26 2012
New Revision: 1403420
URL: http://svn.apache.org/viewvc?rev=1403420&view=rev
Log:
Reverted back to OSGi 4.2 which works.
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
camel/trunk/parent/pom.xml
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=1403420&r1=1403419&r2=1403420&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
Mon Oct 29 16:50:26 2012
@@ -291,6 +291,7 @@ 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<?>>();
@@ -395,11 +396,11 @@ public class Activator implements Bundle
try {
Properties properties = loadProperties(url);
String classname = (String) properties.get("class");
- Class<?> type = bundle.loadClass(classname);
+ Class<T> 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((Class<T>) type);
+ return injector.newInstance(type);
} catch (ClassNotFoundException e) {
throw new IllegalArgumentException("Invalid URI, no " +
this.type.getName() + " registered for scheme : " + name, e);
}
@@ -410,7 +411,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;
@@ -432,7 +433,7 @@ public class Activator implements Bundle
doRegister(type, null);
}
- protected void doRegister(Class<?> type, Dictionary<String, ?> props) {
+ protected void doRegister(Class<?> type, Dictionary<?, ?> 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=1403420&r1=1403419&r2=1403420&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
Mon Oct 29 16:50:26 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();
- Dictionary<String, Object > props = new Hashtable<String,
Object>();
+ Properties props = new Properties();
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=1403420&r1=1403419&r2=1403420&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
Mon Oct 29 16:50:26 2012
@@ -17,7 +17,6 @@
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;
@@ -104,7 +103,7 @@ public class CamelMockBundle extends Moc
}
@Override
- public Map<X509Certificate, List<X509Certificate>>
getSignerCertificates(int signersType) {
+ public Map<?, ?> 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=1403420&r1=1403419&r2=1403420&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
Mon Oct 29 16:50:26 2012
@@ -16,8 +16,7 @@
*/
package org.apache.camel.component.eventadmin;
-import java.util.Dictionary;
-import java.util.Hashtable;
+import java.util.Properties;
import org.apache.camel.spi.ComponentResolver;
import org.osgi.framework.BundleActivator;
@@ -30,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 {
- Dictionary<String, String> props = new Hashtable<String, String>();
+ Properties props = new Properties();
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=1403420&r1=1403419&r2=1403420&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
Mon Oct 29 16:50:26 2012
@@ -16,8 +16,7 @@
*/
package org.apache.camel.component.eventadmin;
-import java.util.Dictionary;
-import java.util.Hashtable;
+import java.util.Properties;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.impl.DefaultConsumer;
@@ -32,7 +31,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) {
@@ -60,7 +59,7 @@ public class EventAdminConsumer extends
@Override
protected void doStart() throws Exception {
super.doStart();
- Dictionary<String, String> props = new Hashtable<String, String>();
+ Properties props = new Properties();
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=1403420&r1=1403419&r2=1403420&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
Mon Oct 29 16:50:26 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<String, ?> props = getProperties(exchange);
+ Dictionary<?, ?> props = getProperties(exchange);
event = new Event(topic, props);
}
return event;
}
- protected Dictionary<String, ?> getProperties(Exchange exchange) {
+ protected Dictionary<?, ?> 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=1403420&r1=1403419&r2=1403420&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
Mon Oct 29 16:50:26 2012
@@ -16,8 +16,7 @@
*/
package org.apache.camel.component.paxlogging;
-import java.util.Dictionary;
-import java.util.Hashtable;
+import java.util.Properties;
import org.apache.camel.spi.ComponentResolver;
import org.osgi.framework.BundleActivator;
@@ -29,10 +28,10 @@ import org.osgi.framework.ServiceRegistr
*/
public class Activator implements BundleActivator {
- private ServiceRegistration<?> registration;
+ private ServiceRegistration registration;
public void start(BundleContext bundleContext) throws Exception {
- Dictionary<String, String> props = new Hashtable<String, String>();
+ Properties props = new Properties();
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=1403420&r1=1403419&r2=1403420&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
Mon Oct 29 16:50:26 2012
@@ -16,8 +16,7 @@
*/
package org.apache.camel.component.paxlogging;
-import java.util.Dictionary;
-import java.util.Hashtable;
+import java.util.Properties;
import java.util.concurrent.ExecutorService;
import org.apache.camel.Exchange;
@@ -45,7 +44,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);
@@ -87,7 +86,7 @@ public class PaxLoggingConsumer extends
@Override
protected void doStart() throws Exception {
super.doStart();
- Dictionary<String, String> props = new Hashtable<String, String>();
+ Properties props = new Properties();
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");
Modified: camel/trunk/parent/pom.xml
URL:
http://svn.apache.org/viewvc/camel/trunk/parent/pom.xml?rev=1403420&r1=1403419&r2=1403420&view=diff
==============================================================================
--- camel/trunk/parent/pom.xml (original)
+++ camel/trunk/parent/pom.xml Mon Oct 29 16:50:26 2012
@@ -254,7 +254,7 @@
<opensaml-version>2.5.1_2</opensaml-version>
<oro-bundle-version>2.0.8_6</oro-bundle-version>
<oscache-bundle-version>2.4_5</oscache-bundle-version>
- <osgi-version>4.3.0</osgi-version>
+ <osgi-version>4.2.0</osgi-version>
<paranamer-bundle-version>2.4_1</paranamer-bundle-version>
<pax-exam-version>2.5.0</pax-exam-version>
<paxexam-karaf-container-version>1.0.0</paxexam-karaf-container-version>
