Adding a tab for remotely managing bundles through a jmx console
- bundlesprobes : is the mbean enabling bundle management
- bundlesprobes.tab : is the graphical component automatically
integrated in the jmxconsole
git-svn-id: https://svn.apache.org/repos/asf/incubator/felix/trunk@438464 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/mosgi.managedelements.bundlesprobes/pom.xml b/mosgi.managedelements.bundlesprobes/pom.xml
new file mode 100644
index 0000000..406604c
--- /dev/null
+++ b/mosgi.managedelements.bundlesprobes/pom.xml
@@ -0,0 +1,67 @@
+<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>MOSGi JMX MBean for OSGi bundles management</name>
+ <artifactId>org.apache.felix.mosgi.managedelements.bundlesprobes</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>
+ <dependency>
+ <groupId>${pom.groupId}</groupId>
+ <artifactId>org.apache.felix.mosgi.console.ifc</artifactId>
+ <version>${pom.version}</version>
+ <scope>provided</scope>
+ </dependency>
+ <dependency>
+ <groupId>${pom.groupId}</groupId>
+ <artifactId>org.apache.felix.framework</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>MOSGi JMX MBean for OSGi bundles management</bundleName>
+ <bundleDescription>MOSGi JMX MBean for OSGi bundles management</bundleDescription>
+ <bundleActivator>auto-detect</bundleActivator>
+ <bundleDocUrl>http://oscar-osgi.sf.net/obr2/${pom.artifactId}/</bundleDocUrl>
+ <bundleUrl>http://oscar-osgi.sf.net/obr2/${pom.artifactId}/${pom.artifactId}-${pom.version}.jar</bundleUrl>
+ <bundleSource>http://oscar-osgi.sf.net/obr2/${pom.artifactId}/${pom.artifactId}-${pom.version}-src.jar</bundleSource>
+ <bundleSymbolicName>${pom.artifactId}</bundleSymbolicName>
+ <exportPackage>
+ ${pom.artifactId};specification-version="1.0.0"
+ </exportPackage>
+ <importPackage>
+ org.osgi.framework;specification-version="1.0.0",
+ org.osgi.service.log;specification-version="1.0.0",
+ javax.management;specification-version="1.0.0",
+ org.apache.felix.mosgi.console.ifc;specification-version="1.0.0"
+ </importPackage>
+ </osgiManifest>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+</project>
diff --git a/mosgi.managedelements.bundlesprobes/src/main/java/org/apache/felix/mosgi/managedelements/bundlesprobes/BundlesProbes.java b/mosgi.managedelements.bundlesprobes/src/main/java/org/apache/felix/mosgi/managedelements/bundlesprobes/BundlesProbes.java
new file mode 100644
index 0000000..42b17cb
--- /dev/null
+++ b/mosgi.managedelements.bundlesprobes/src/main/java/org/apache/felix/mosgi/managedelements/bundlesprobes/BundlesProbes.java
@@ -0,0 +1,251 @@
+/*
+ * Copyright 2005 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.mosgi.managedelements.bundlesprobes;
+
+/**
+ * TODO : Should listen to Agent Service lifecycle
+ * Need to change ObjectName
+ * Should listen to serviceLifecycle
+**/
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Properties;
+import java.util.Vector;
+
+import javax.management.MBeanServer;
+import javax.management.MBeanServerFactory;
+import javax.management.ObjectName;
+import javax.management.NotificationBroadcasterSupport;
+import javax.management.AttributeChangeNotification;
+
+import org.osgi.framework.Bundle;
+import org.osgi.framework.BundleActivator;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.BundleEvent;
+import org.osgi.framework.BundleException;
+import org.osgi.framework.BundleListener;
+import org.osgi.framework.Constants;
+import org.osgi.framework.ServiceEvent;
+import org.osgi.framework.ServiceListener;
+import org.osgi.framework.ServiceReference;
+
+
+import org.osgi.service.log.LogService;
+
+public class BundlesProbes extends NotificationBroadcasterSupport implements BundleActivator, BundlesProbesMBean, ServiceListener, BundleListener {
+
+ private String version = null;
+ private static String tabNameString = "TabUI:name=BundlesProbes";
+
+ private ObjectName tabName = null;
+ private MBeanServer server = null;
+ private BundleContext bc = null;
+ private ServiceReference sr = null;
+
+
+ ////////////////////////////////////////////////////////
+ // TabIfc (from BundlesProbesMBean) //
+ ////////////////////////////////////////////////////////
+ public String getBundleName() {
+ return this.bc.getProperty("insa.jmxconsole.tab.url.bundlesprobestab");
+ }
+
+
+ ////////////////////////////////////////////////////////
+ // BundleActivator //
+ ////////////////////////////////////////////////////////
+ public void start(BundleContext context) throws Exception {
+ this.bc=context;
+ this.version=(String)bc.getBundle().getHeaders().get(Constants.BUNDLE_VERSION);
+ this.log(LogService.LOG_INFO, "Starting BundlesProbe MBean " + this.version,null);
+ this.tabName=new ObjectName(tabNameString);
+ this.sr = context.getServiceReference(MBeanServer.class.getName());
+ if (sr!=null){
+ this.connectToAgent(sr);
+ }
+ this.log(LogService.LOG_INFO, "BundlesProbes MBean "+this.version+" started", null);
+ }
+
+
+ public void stop(BundleContext context) {
+ this.log(LogService.LOG_INFO, "Stopping BundlesProbes MBean "+this.version, null);
+ if (this.server!=null){
+ this.disconnectFromAgent();
+ }
+ this.sr=null;
+ this.log(LogService.LOG_INFO, "BundlesProbes MBean "+this.version+" stopped", null);
+ this.bc=null;
+ }
+
+ ////////////////////////////////////////////////////////
+ // BundlesProbesMBean //
+ ////////////////////////////////////////////////////////
+ public Vector bundleList() {
+ Bundle[] bl = this.bc.getBundles();
+ Vector bundleList = new Vector();
+ Vector bundle = null;
+ for (int i = 0; i < bl.length; i++) {
+ bundle = new Vector();
+ String enum1 = (String) bl[i].getHeaders().get(Constants.BUNDLE_NAME);
+ long id = bl[i].getBundleId();
+ bundle.add(new Long(id));
+ int state = bl[i].getState();
+ switch (state) {
+ case Bundle.ACTIVE:
+ bundle.add(new String("ACTIVE"));
+ break;
+ case Bundle.INSTALLED:
+ bundle.add(new String("INSTALLED"));
+ break;
+ case Bundle.RESOLVED:
+ bundle.add(new String("RESOLVED"));
+ break;
+ case Bundle.UNINSTALLED:
+ bundle.add(new String("UNINSTALLED"));
+ break;
+ default:
+ bundle.add(new String("RESOLVED"));
+ }
+ bundle.add(enum1);
+ bundleList.add(bundle);
+ }
+ return bundleList;
+ }
+
+ public void startService(Long [] id) {
+ try {
+ bc.getBundle(id[0].longValue()).start();
+ } catch (BundleException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void stopService(Long [] id) {
+ try {
+ bc.getBundle(id[0].longValue()).stop();
+ } catch (BundleException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void install(String location) {
+ try {
+ bc.installBundle(location);
+ } catch (BundleException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void uninstall(Long [] id) {
+ try {
+ bc.getBundle(id[0].longValue()).uninstall();
+ } catch (BundleException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void update(Long [] id) {
+ try {
+ bc.getBundle(id[0].longValue()).update();
+ } catch (BundleException e) {
+ e.printStackTrace();
+ }
+ }
+
+ ////////////////////////////////////////////////////////
+ // ServiceListener //
+ ////////////////////////////////////////////////////////
+ public void serviceChanged(ServiceEvent event) {
+ ServiceReference sr=event.getServiceReference();
+ Object service=bc.getService(sr);
+ if (this.server==null && event.getType()==ServiceEvent.REGISTERED && service instanceof MBeanServer){
+ this.connectToAgent(sr);
+ }
+ if (this.server!=null){
+ if(event.getType()==ServiceEvent.UNREGISTERING && service instanceof MBeanServer){
+ this.disconnectFromAgent();
+ }else{
+ this.sendRemoteNotification(ServiceEvent.class.getName(),sr.getBundle().getBundleId(), event.getType(), (String)sr.getBundle().getHeaders().get(Constants.BUNDLE_NAME));
+ }
+ }
+ }
+
+ ////////////////////////////////////////////////////////
+ // BundleListener //
+ ////////////////////////////////////////////////////////
+ public void bundleChanged(BundleEvent event) {
+ if (this.server!=null){
+ Bundle b=event.getBundle();
+ //SFR this.sendRemoteNotification(BundleEvent.class.getName(), b.getBundleId(), b.getState(), (String)b.getHeaders().get(Constants.BUNDLE_NAME));
+System.out.println("Evenement bundle "+b.getBundleId()+" : "+event.getType());
+ this.sendRemoteNotification(BundleEvent.class.getName(), b.getBundleId(), event.getType(), (String)b.getHeaders().get(Constants.BUNDLE_NAME));
+ }
+ }
+
+ private void sendRemoteNotification(String className, long id, int type, String name){
+ StringBuffer str = new StringBuffer(className);
+ str.append(":");
+ str.append(id);
+ str.append(":");
+ str.append(type);
+ str.append(":");
+ str.append(name);
+ super.sendNotification(new AttributeChangeNotification(this.tabName, 0, 0,str.toString(),null, "Bundle", null, null));
+ }
+
+ private void connectToAgent(ServiceReference sr){
+ this.log(LogService.LOG_INFO, "Registering to agent", null);
+ try{
+ this.server=(MBeanServer)this.bc.getService(sr);
+ this.server.registerMBean(this, tabName);
+ this.bc.addServiceListener(this);
+ this.bc.addBundleListener(this);
+ }catch (Exception e){
+ e.printStackTrace();
+ }
+ this.log(LogService.LOG_INFO, "Registered to agent", null);
+ }
+
+ private void disconnectFromAgent(){
+ this.log(LogService.LOG_INFO, "Unregistering from agent", null);
+ this.bc.removeServiceListener(this);
+ this.bc.removeBundleListener(this);
+ try {
+ server.unregisterMBean(tabName);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ this.server=null;
+ this.bc.ungetService(this.sr);
+ this.log(LogService.LOG_INFO, "Unregistered from agent", null);
+ }
+
+ private void log(int prio, String message, Throwable t){
+ if (this.bc!=null){
+ ServiceReference logSR=this.bc.getServiceReference(LogService.class.getName());
+ if (logSR!=null){
+ ((LogService)this.bc.getService(logSR)).log(prio, message, t);
+ }else{
+ System.out.println("No Log Service");
+ }
+ }else{
+ System.out.println(this.getClass().getName()+".log: No bundleContext");
+ }
+ }
+
+}
diff --git a/mosgi.managedelements.bundlesprobes/src/main/java/org/apache/felix/mosgi/managedelements/bundlesprobes/BundlesProbesMBean.java b/mosgi.managedelements.bundlesprobes/src/main/java/org/apache/felix/mosgi/managedelements/bundlesprobes/BundlesProbesMBean.java
new file mode 100644
index 0000000..4b3dfba
--- /dev/null
+++ b/mosgi.managedelements.bundlesprobes/src/main/java/org/apache/felix/mosgi/managedelements/bundlesprobes/BundlesProbesMBean.java
@@ -0,0 +1,29 @@
+/*
+ * Copyright 2005 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.mosgi.managedelements.bundlesprobes;
+import org.apache.felix.mosgi.console.ifc.TabIfc;
+import java.util.Vector;
+
+public interface BundlesProbesMBean extends TabIfc {
+ public Vector bundleList();
+
+ public void startService(Long [] id);
+ public void stopService(Long [] id);
+ public void install(String location);
+ public void uninstall(Long[] id);
+ public void update(Long [] id);
+}