Implement mappings from WireAdminEvents (FELIX-86)
git-svn-id: https://svn.apache.org/repos/asf/incubator/felix/trunk@416927 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/org.apache.felix.eventadmin.bridge.wireadmin/pom.xml b/org.apache.felix.eventadmin.bridge.wireadmin/pom.xml
new file mode 100644
index 0000000..d35fbe1
--- /dev/null
+++ b/org.apache.felix.eventadmin.bridge.wireadmin/pom.xml
@@ -0,0 +1,46 @@
+<project>
+ <parent>
+ <groupId>org.apache.felix</groupId>
+ <artifactId>felix</artifactId>
+ <version>0.8.0-SNAPSHOT</version>
+ </parent>
+ <modelVersion>4.0.0</modelVersion>
+ <packaging>osgi-bundle</packaging>
+ <name>Apache Felix EventAdmin Bridge WireAdmin</name>
+ <artifactId>org.apache.felix.eventadmin.bridge.wireadmin</artifactId>
+ <dependencies>
+ <dependency>
+ <groupId>${pom.groupId}</groupId>
+ <artifactId>org.osgi.core</artifactId>
+ <version>${pom.version}</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>${pom.groupId}</groupId>
+ <artifactId>org.osgi.compendium</artifactId>
+ <version>${pom.version}</version>
+ <scope>provided</scope>
+ </dependency>
+ </dependencies>
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.felix.plugins</groupId>
+ <artifactId>maven-osgi-plugin</artifactId>
+ <version>${pom.version}</version>
+ <extensions>true</extensions>
+ <configuration>
+ <osgiManifest>
+ <bundleName>EventAdmin Bridge WireAdmin</bundleName>
+ <bundleVendor>Apache Software Foundation</bundleVendor>
+ <bundleDescription>
+ This bundle provides a bridge between WireAdmin and EventAdmin events.
+ </bundleDescription>
+ <bundleActivator>auto-detect</bundleActivator>
+ <bundleSymbolicName>${pom.artifactId}</bundleSymbolicName>
+ </osgiManifest>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/org.apache.felix.eventadmin.bridge.wireadmin/src/main/java/org/apache/felix/eventadmin/bridge/wireadmin/Activator.java b/org.apache.felix.eventadmin.bridge.wireadmin/src/main/java/org/apache/felix/eventadmin/bridge/wireadmin/Activator.java
new file mode 100644
index 0000000..ab0245b
--- /dev/null
+++ b/org.apache.felix.eventadmin.bridge.wireadmin/src/main/java/org/apache/felix/eventadmin/bridge/wireadmin/Activator.java
@@ -0,0 +1,53 @@
+/*
+ * Copyright 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package org.apache.felix.eventadmin.bridge.wireadmin;
+
+import org.osgi.framework.BundleActivator;
+import org.osgi.framework.BundleContext;
+
+/**
+ * The BundleActivator that will register an WireAdminEventListener service with the
+ * framework on start. Subsequently, WireAdminEvents will be bridged to available
+ * EventAdmin services (as per spec).
+ *
+ * @author <a href="mailto:felix-dev@incubator.apache.org">Felix Project Team</a>
+ */
+public class Activator implements BundleActivator
+{
+ /**
+ * This registers an WireAdminEventListener service with the framework that bridges
+ * WireAdminEvents to the EventAdmin.
+ *
+ * @param context The context to use
+ *
+ * @see org.osgi.framework.BundleActivator#start(org.osgi.framework.BundleContext)
+ */
+ public void start(final BundleContext context) throws Exception
+ {
+ new WireAdminEventToEventAdminBridge(context);
+ }
+
+ /**
+ * Stop the bridging of WireAdminEvents to the EventAdmin.
+ *
+ * @see org.osgi.framework.BundleActivator#stop(org.osgi.framework.BundleContext)
+ */
+ public void stop(final BundleContext context) throws Exception
+ {
+ // Services are unregistered by the framework
+ }
+}
diff --git a/org.apache.felix.eventadmin.bridge.wireadmin/src/main/java/org/apache/felix/eventadmin/bridge/wireadmin/WireAdminEventToEventAdminBridge.java b/org.apache.felix.eventadmin.bridge.wireadmin/src/main/java/org/apache/felix/eventadmin/bridge/wireadmin/WireAdminEventToEventAdminBridge.java
new file mode 100644
index 0000000..efe0a1e
--- /dev/null
+++ b/org.apache.felix.eventadmin.bridge.wireadmin/src/main/java/org/apache/felix/eventadmin/bridge/wireadmin/WireAdminEventToEventAdminBridge.java
@@ -0,0 +1,162 @@
+/*
+ * Copyright 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+package org.apache.felix.eventadmin.bridge.wireadmin;
+
+import java.util.Arrays;
+import java.util.Hashtable;
+
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.Constants;
+import org.osgi.framework.ServiceReference;
+import org.osgi.service.event.Event;
+import org.osgi.service.event.EventAdmin;
+import org.osgi.service.event.EventConstants;
+import org.osgi.service.wireadmin.WireAdmin;
+import org.osgi.service.wireadmin.WireAdminEvent;
+import org.osgi.service.wireadmin.WireAdminListener;
+
+/**
+ * @author <a href="mailto:felix-dev@incubator.apache.org">Felix Project Team</a>
+ */
+public class WireAdminEventToEventAdminBridge implements WireAdminListener
+{
+ private final BundleContext m_context;
+
+ public WireAdminEventToEventAdminBridge(final BundleContext context)
+ {
+ m_context = context;
+
+ m_context
+ .registerService(WireAdminListener.class.getName(), this, null);
+ }
+
+ public void wireAdminEvent(final WireAdminEvent event)
+ {
+ final ServiceReference ref = m_context
+ .getServiceReference(EventAdmin.class.getName());
+
+ if(null != ref)
+ {
+ final EventAdmin eventAdmin = (EventAdmin) m_context
+ .getService(ref);
+
+ if(null != eventAdmin)
+ {
+ final String topic;
+
+ switch(event.getType())
+ {
+ case WireAdminEvent.WIRE_CREATED:
+ topic = "org/osgi/service/wireadmin/WireAdminEvent/WIRE_CREATED";
+ break;
+ case WireAdminEvent.WIRE_CONNECTED:
+ topic = "org/osgi/service/wireadmin/WireAdminEvent/WIRE_CONNECTED";
+ break;
+ case WireAdminEvent.WIRE_UPDATED:
+ topic = "org/osgi/service/wireadmin/WireAdminEvent/WIRE_UPDATED";
+ break;
+ case WireAdminEvent.WIRE_TRACE:
+ topic = "org/osgi/service/wireadmin/WireAdminEvent/WIRE_TRACE";
+ break;
+ case WireAdminEvent.WIRE_DISCONNECTED:
+ topic = "org/osgi/service/wireadmin/WireAdminEvent/WIRE_DISCONNECTED";
+ break;
+ case WireAdminEvent.WIRE_DELETED:
+ topic = "org/osgi/service/wireadmin/WireAdminEvent/WIRE_DELETED";
+ break;
+ case WireAdminEvent.PRODUCER_EXCEPTION:
+ topic = "org/osgi/service/wireadmin/WireAdminEvent/PRODUCER_EXCEPTION";
+ break;
+ case WireAdminEvent.CONSUMER_EXCEPTION:
+ topic = "org/osgi/service/wireadmin/WireAdminEvent/CONSUMER_EXCEPTION";
+ break;
+ default:
+ m_context.ungetService(ref);
+ return;
+ }
+
+ eventAdmin.postEvent(new Event(topic, new Hashtable()
+ {
+ {
+ put(EventConstants.EVENT, event);
+
+ put("wire", event.getWire());
+
+ put("wire.flavors", event.getWire().getFlavors());
+
+ put("wire.scope", event.getWire().getScope());
+
+ put("wire.connected", Boolean.valueOf(event.getWire()
+ .isConnected()));
+
+ put("wire.valid", Boolean.valueOf(event.getWire()
+ .isValid()));
+
+ final Throwable throwable = event.getThrowable();
+
+ if(null != throwable)
+ {
+ put(EventConstants.EXCEPTION, throwable);
+
+ put(EventConstants.EXCEPTION_CLASS, throwable
+ .getClass().getName());
+
+ final String message = throwable.getMessage();
+
+ if(null != message)
+ {
+ put(EventConstants.EXCEPTION_MESSAGE, message);
+ }
+
+ final ServiceReference ref = event
+ .getServiceReference();
+
+ if(null == ref)
+ {
+ throw new IllegalArgumentException(
+ "WireAdminEvent.getServiceReference() may not be null");
+ }
+
+ put(EventConstants.SERVICE, ref);
+
+ put(EventConstants.SERVICE_ID, ref
+ .getProperty(EventConstants.SERVICE_ID));
+
+ final Object objectClass = ref
+ .getProperty(Constants.OBJECTCLASS);
+
+ if(!(objectClass instanceof String[])
+ || !Arrays.asList((String[]) objectClass)
+ .contains(WireAdmin.class.getName()))
+ {
+ throw new IllegalArgumentException(
+ "Bad objectclass: " + objectClass);
+ }
+
+ put(EventConstants.SERVICE_OBJECTCLASS, objectClass);
+
+ put(EventConstants.SERVICE_PID, ref
+ .getProperty(EventConstants.SERVICE_PID));
+ }
+ }
+ }));
+
+ m_context.ungetService(ref);
+ }
+ }
+ }
+}