felix-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From don...@apache.org
Subject svn commit: r612292 - in /felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer: ./ src/ src/main/ src/main/java/ src/main/java/org/ src/main/java/org/apache/ src/main/java/org/apache/felix/ src/main/java/org/apache/felix/sandbox/ src/main/j...
Date Tue, 15 Jan 2008 23:05:27 GMT
Author: donsez
Date: Tue Jan 15 15:05:25 2008
New Revision: 612292

URL: http://svn.apache.org/viewvc?rev=612292&view=rev
Log:
creation of the "Fictive Measurement Producer" bundle : a Producer example that poll Measurement
objects according to a function sin().

Added:
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/pom.xml   (with props)
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/config/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/config/Configuration.java
  (with props)
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/measurement/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/measurement/UnitUtil.java
  (with props)
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/wireadmin/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/wireadmin/sample/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/wireadmin/sample/fictivemeasurementproducer/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/wireadmin/sample/fictivemeasurementproducer/MeasurementProducer.java
  (with props)
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/resources/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/resources/config.properties
  (with props)
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/site/
    felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/site/readme.html
  (with props)

Added: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/pom.xml
URL: http://svn.apache.org/viewvc/felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/pom.xml?rev=612292&view=auto
==============================================================================
--- felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/pom.xml (added)
+++ felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/pom.xml Tue Jan 15 15:05:25
2008
@@ -0,0 +1,72 @@
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one
+ or more contributor license agreements.  See the NOTICE file
+ distributed with this work for additional information
+ regarding copyright ownership.  The ASF licenses this file
+ to you 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.
+-->
+<project>
+	<properties>
+		<repositoryLocation>http://people.apache.org/~donsez/dev/felix/sandbox/</repositoryLocation>
+		<description>a example of a producer for the Wire Admin service.</description>
+	</properties>  
+
+  <modelVersion>4.0.0</modelVersion>
+  <packaging>bundle</packaging>
+  <name>Fictive Measurement Producer</name>
+  <description>${description}</description>
+  <groupId>org.apache.felix.sandbox</groupId>
+  <version>0.1.0-SNAPSHOT</version>
+  <artifactId>wireadmin.sample.fictivemeasurementproducer</artifactId>
+
+  <dependencies>
+
+	<dependency>
+		<groupId>org.apache.felix</groupId>
+		<artifactId>org.osgi.core</artifactId>
+  		<version>1.1.0-SNAPSHOT</version>
+	</dependency>
+	
+	<dependency>
+		<groupId>org.apache.felix</groupId>
+		<artifactId>org.osgi.compendium</artifactId>
+  		<version>0.9.0-SNAPSHOT</version>
+	</dependency>
+        
+  </dependencies>
+  
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.felix</groupId>
+        <artifactId>maven-bundle-plugin</artifactId>
+        <extensions>true</extensions>
+        <configuration>
+          <instructions>
+            <Import-Package>*</Import-Package>
+            <Private-Package>
+              ${pom.groupId}.${pom.artifactId},
+              ${pom.groupId}.util.*
+            </Private-Package>
+           	<Bundle-Activator>${pom.groupId}.${pom.artifactId}.MeasurementProducer</Bundle-Activator>
+            
+            <!-- docs in http://cwiki.apache.org/FELIX/bundle-plugin-for-maven-bnd.html
and http://cwiki.apache.org/FELIX/osgi-plugin-for-maven-2.html -->
+            <Export-Service>org.osgi.service.wireadmin.Producer</Export-Service>
+                        
+          </instructions>
+        </configuration>
+      </plugin>
+    </plugins>
+  </build>
+</project>

Propchange: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/pom.xml
------------------------------------------------------------------------------
    svn:eol-style = native

Added: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/config/Configuration.java
URL: http://svn.apache.org/viewvc/felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/config/Configuration.java?rev=612292&view=auto
==============================================================================
--- felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/config/Configuration.java
(added)
+++ felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/config/Configuration.java
Tue Jan 15 15:05:25 2008
@@ -0,0 +1,217 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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.sandbox.util.config;
+
+import java.io.FileInputStream;
+import java.io.InputStream;
+import java.util.Hashtable;
+import java.util.Map;
+import java.util.Properties;
+import java.util.StringTokenizer;
+import java.util.Vector;
+
+/**
+ * configuration utility
+ * 
+ * @author <a href="mailto:dev@felix.apache.org">Felix Project Team</a>
+ */
+public class Configuration {
+	static String DEFAULT_PROPERTIES_FILE = "config.properties";
+
+	/**
+	 * loads properties from a file
+	 * 
+	 * @param filename
+	 *            the properties file name
+	 * @return the properties
+	 */
+	public static Properties loadProperties(String filename) {
+		if (filename == null) {
+			filename = System.getProperty(
+					"org.apache.felix.sandbox.util.configuration.file",
+					DEFAULT_PROPERTIES_FILE);
+		}
+		try {
+			return loadProperties(new FileInputStream(filename));
+		} catch (Exception ex) {
+			ex.printStackTrace();
+			return null;
+		}
+	}
+
+	/**
+	 * loads properties from a input stream
+	 * 
+	 * @param in
+	 *            the imput stream
+	 * @return the properties
+	 */
+	public static Properties loadProperties(InputStream in) {
+		Properties prop = new Properties();
+		try {
+			prop.load(in);
+		} catch (Exception ex) {
+			ex.printStackTrace();
+			return null;
+		}
+		return prop;
+	}
+
+	/**
+	 * builds a map from properties. the key list is in the property
+	 * keyListPropertyName <br>
+	 * Example getMap(props,"keylist") returns a hashtable with 3 key-value
+	 * entry
+	 * 
+	 * <pre>
+	 *  keylist=bar;bubba;foo
+	 *  bar=BAR
+	 *  foo=1.5;float
+	 *  bubba=100;int
+	 * </pre>
+	 * 
+	 * @param props
+	 *            the properties
+	 * @param keyListPropertyName
+	 *            the property name of the key list (separed by ;)
+	 * @return The map
+	 */
+	public static Map getMap(Properties props, String keyListPropertyName) {
+		return getHashtable(props, keyListPropertyName);
+	}
+
+	/**
+	 * builds a hashtable from properties. the key list is in the property
+	 * keyListPropertyName <br>
+	 * Example getHashtable(props,"keylist") returns a hashtable with 3
+	 * key-value entry
+	 * 
+	 * <pre>
+	 *  keylist=bar;bubba;foo
+	 *  bar=BAR
+	 *  foo=1.5;float
+	 *  bubba=100;int
+	 * </pre>
+	 * 
+	 * @param props
+	 *            the properties
+	 * @param keyListPropertyName
+	 *            the property name of the key list (separed by ;)
+	 * @return The hashtable
+	 */
+	public static Hashtable getHashtable(Properties props,
+			String keyListPropertyName) {
+
+		StringTokenizer st = new StringTokenizer(props
+				.getProperty(keyListPropertyName), ";");
+		Hashtable map = new Hashtable();
+
+		while (st.hasMoreTokens()) {
+			String key = st.nextToken();
+			StringTokenizer stvaluetype = new StringTokenizer(props
+					.getProperty(key), ";");
+			Object obj = null;
+			if (stvaluetype.hasMoreTokens()) {
+				String value = stvaluetype.nextToken();
+				if (stvaluetype.hasMoreTokens()) {
+					String type = stvaluetype.nextToken();
+					if (type.equals("int")) {
+						obj = new Integer(value);
+					} else if (type.equals("long")) {
+						obj = new Long(value);
+					} else if (type.equals("float")) {
+						obj = new Float(value);
+					} else if (type.equals("double")) {
+						obj = new Double(value);
+					} else if (type.equals("string")) {
+						obj = value;
+					} else {
+						// default : string
+						obj = value;
+					}
+				} else {
+					// no type means String
+					obj = value;
+				}
+
+			}
+			map.put(key, obj);
+		}
+		return map;
+	}
+
+	/**
+	 * builds a (ordered) vector from properties. the index list is in the
+	 * property keyListPropertyName <br>
+	 * Example getVector(props,"tab") returns a 4 elements vector (tab.5 is
+	 * ignored since tab.4 does not exist)
+	 * 
+	 * <pre>
+	 *  tab.0=bar
+	 *  tab.1=foo
+	 *  tab.2=1.5;float
+	 *  tab.3=100;int
+	 *  tab.5=10000;long
+	 * </pre>
+	 * 
+	 * @param props
+	 *            the properties
+	 * @param vectorPropertyName
+	 *            the property name of the key list (separed by ;)
+	 * @return The vector
+	 */
+	public static Vector getVector(Properties props, String vectorPropertyName) {
+
+		Vector vect = new Vector();
+
+		for (int i = 0; true; i++) {
+			String valuetype = props.getProperty(vectorPropertyName) + "." + i;
+			if (valuetype == null)
+				break;
+			StringTokenizer stvaluetype = new StringTokenizer(valuetype, ";");
+			Object obj = null;
+			if (stvaluetype.hasMoreTokens()) {
+				String value = stvaluetype.nextToken();
+				if (stvaluetype.hasMoreTokens()) {
+					String type = stvaluetype.nextToken();
+					if (type.equals("int")) {
+						obj = new Integer(value);
+					} else if (type.equals("long")) {
+						obj = new Long(value);
+					} else if (type.equals("float")) {
+						obj = new Float(value);
+					} else if (type.equals("double")) {
+						obj = new Double(value);
+					} else if (type.equals("string")) {
+						obj = value;
+					} else {
+						// default : string
+						obj = value;
+					}
+				} else {
+					// no type means String
+					obj = value;
+				}
+
+			}
+			vect.addElement(obj);
+		}
+		return vect;
+	}
+}

Propchange: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/config/Configuration.java
------------------------------------------------------------------------------
    svn:eol-style = native

Added: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/measurement/UnitUtil.java
URL: http://svn.apache.org/viewvc/felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/measurement/UnitUtil.java?rev=612292&view=auto
==============================================================================
--- felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/measurement/UnitUtil.java
(added)
+++ felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/measurement/UnitUtil.java
Tue Jan 15 15:05:25 2008
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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.sandbox.util.measurement;
+
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+
+import org.osgi.util.measurement.Unit;
+
+/**
+ * @author <a href="mailto:dev@felix.apache.org">Felix Project Team</a>
+ */
+
+public class UnitUtil {
+
+	private static Map mapString2Unit = new HashMap();
+	static {
+		mapString2Unit.put("A", Unit.A);
+		mapString2Unit.put("C", Unit.C);
+		mapString2Unit.put("cd", Unit.cd);
+		mapString2Unit.put("F", Unit.F);
+		mapString2Unit.put("Gy", Unit.Gy);
+		mapString2Unit.put("Hz", Unit.Hz);
+		mapString2Unit.put("J", Unit.J);
+		mapString2Unit.put("K", Unit.K);
+		mapString2Unit.put("kat", Unit.kat);
+		mapString2Unit.put("kg", Unit.kg);
+		mapString2Unit.put("lx", Unit.lx);
+		mapString2Unit.put("m", Unit.m);
+		mapString2Unit.put("m2", Unit.m2);
+		mapString2Unit.put("m3", Unit.m3);
+		mapString2Unit.put("m_s", Unit.m_s);
+		mapString2Unit.put("m_s2", Unit.m_s2);
+		mapString2Unit.put("mol", Unit.mol);
+		mapString2Unit.put("N", Unit.N);
+		mapString2Unit.put("Ohm", Unit.Ohm);
+		mapString2Unit.put("Pa", Unit.Pa);
+		mapString2Unit.put("rad", Unit.rad);
+		mapString2Unit.put("S", Unit.S);
+		mapString2Unit.put("s", Unit.s);
+		mapString2Unit.put("T", Unit.T);
+		mapString2Unit.put("unity", Unit.unity);
+		mapString2Unit.put("V", Unit.V);
+		mapString2Unit.put("W", Unit.W);
+		mapString2Unit.put("Wb", Unit.Wb);
+	}
+
+	public static Unit getUnitFromString(String str){
+	    return (Unit) mapString2Unit.get(str);
+	}
+	
+	public static String getStringFromUnit(Unit unit){
+	    Iterator iter=mapString2Unit.entrySet().iterator();
+	    while(iter.hasNext()){
+	        Map.Entry mapEntry=(Map.Entry)iter.next();
+	        if(unit.equals(mapEntry.getValue()))
+	            return (String) mapEntry.getKey();
+	    }	    
+	    return null;
+	}
+	
+}

Propchange: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/util/measurement/UnitUtil.java
------------------------------------------------------------------------------
    svn:eol-style = native

Added: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/wireadmin/sample/fictivemeasurementproducer/MeasurementProducer.java
URL: http://svn.apache.org/viewvc/felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/wireadmin/sample/fictivemeasurementproducer/MeasurementProducer.java?rev=612292&view=auto
==============================================================================
--- felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/wireadmin/sample/fictivemeasurementproducer/MeasurementProducer.java
(added)
+++ felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/wireadmin/sample/fictivemeasurementproducer/MeasurementProducer.java
Tue Jan 15 15:05:25 2008
@@ -0,0 +1,244 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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.sandbox.wireadmin.sample.fictivemeasurementproducer;
+
+import java.io.InputStream;
+import java.io.PrintStream;
+import java.util.Dictionary;
+import java.util.Enumeration;
+import java.util.Hashtable;
+import java.util.Properties;
+
+import org.apache.felix.sandbox.util.config.Configuration;
+import org.apache.felix.sandbox.util.measurement.UnitUtil;
+import org.osgi.framework.BundleActivator;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.ServiceRegistration;
+import org.osgi.service.wireadmin.Producer;
+import org.osgi.service.wireadmin.Wire;
+import org.osgi.util.measurement.Measurement;
+import org.osgi.util.measurement.Unit;
+
+
+/**
+ * The class provides a producer of random measurements 
+ * It's a sample for the Wire Admin service
+ * @author <a href="mailto:dev@felix.apache.org">Felix Project Team</a>
+ * TODO check synchronizations on wires[]
+ * TODO takes into account wireadmin.filter http://www2.osgi.org/javadoc/r4/org/osgi/service/wireadmin/WireConstants.html#WIREADMIN_FILTER
+ * TODO add pause when no wires are created, connected or valid
+ */
+public class MeasurementProducer implements Producer, Runnable, BundleActivator {
+
+	private Wire wires[];
+	private ServiceRegistration serviceRegistration;
+	
+	private int pollDelay;
+	private double max;
+	private double min;
+	private Unit unit;
+	private double error;
+	private long period;
+	private PrintStream traceout;
+
+	private boolean quit;
+
+	private static final String CONFIGFILE = "/config.properties";
+
+	protected BundleContext bundleContext = null;
+
+	/**
+	 * Load the configuration properties and register e new service
+	 */
+	private void configure() throws Exception {
+
+		// Get the Config-Location value from the manifest
+
+		String configLocation = null;
+		Dictionary dict = bundleContext.getBundle().getHeaders();
+		Enumeration enumeration = dict.keys();
+		while (enumeration.hasMoreElements()) {
+			Object nextKey = enumeration.nextElement();
+			Object nextElem = dict.get(nextKey);
+			if (nextKey.equals("Config-Location")) {
+				configLocation = nextElem.toString();
+				break;
+			}
+		}
+		if (configLocation == null) {
+			configLocation = CONFIGFILE;
+		}
+
+		// Load properties from configLocation file
+		InputStream is = getClass().getResourceAsStream(configLocation);
+		Properties props = Configuration.loadProperties(is);
+
+		String ptraceout = props.getProperty("traceout");
+		traceout = null;
+		if (ptraceout != null) {
+			if (ptraceout.equals("System.out")) {
+				traceout = System.out;
+			} else if (ptraceout.equals("System.err")) {
+				traceout = System.err;
+			} else {
+				// TODO instanciante the class with the name	
+				System.err.println("custom trace is not implemented !");
+			}
+		} else {
+			traceout = null;
+		}
+
+		String polldelayprops = props.getProperty("poll.delay");
+		pollDelay = 1000; // default 1000 millisec
+		if (polldelayprops != null) {
+			pollDelay = Integer.parseInt(polldelayprops);
+		}
+
+		String propsmin = props.getProperty("measurement.min");
+		min = 273.0;
+		if (propsmin != null) {
+			min = Double.parseDouble(propsmin);
+		}
+
+		String propmax = props.getProperty("measurement.max");
+		max = 293.0;
+		if (propmax != null) {
+			max = Double.parseDouble(propmax);
+		}
+
+		String propserror = props.getProperty("measurement.error");
+		error = 0.5;
+		if (propsmin != null) {
+			error = Double.parseDouble(propserror);
+		}
+		String propsunit = props.getProperty("measurement.unit");
+		if(propsunit==null){
+		    unit=Unit.K;
+		} else {
+		    unit = UnitUtil.getUnitFromString(propsunit);
+		}
+		
+		String periodprops = props.getProperty("measurement.sinusperiod");
+		pollDelay = 120000; // default 1000 millisec
+		if (periodprops != null) {
+			period = Long.parseLong(periodprops);
+		}
+
+		
+	}
+
+	
+	
+	/**
+	 * @see java.lang.Runnable#run()
+	 */
+	public synchronized void run() {
+		while (!quit){
+			try {
+				Measurement measurement = getMeasurement();
+				for (int i = 0; wires != null && i < wires.length; i++) {
+					Wire wire = wires[i];
+					// check if wire is valid and connected ?
+					if (!wire.isConnected() || !wire.isValid())
+						continue;
+					Object obj=polled(wire,measurement);
+					// TODO : respect the control flow specified by the consumer
+					if(obj!=null) wire.update(obj);
+				}
+				Thread.sleep(pollDelay);
+			} catch (InterruptedException ie) {
+				/* will recheck quit */
+			}
+		}
+	}
+
+	/**
+	 * @see org.osgi.service.wireadmin.Producer#consumersConnected(org.osgi.service.wireadmin.Wire[])
+	 */
+	public synchronized void consumersConnected(Wire wires[]) {
+		this.wires = wires;
+	}
+
+	/**
+	 * @see org.osgi.service.wireadmin.Producer#polled(org.osgi.service.wireadmin.Wire)
+	 */
+	public Object polled(Wire wire) {
+		return polled(wire,getMeasurement());
+	}
+
+	private Object polled(Wire wire,Measurement measurement) {
+		Class clazzes[] = wire.getFlavors();
+		for (int i = 0; i < clazzes.length; i++) {
+			Class clazz = clazzes[i];
+			if (clazz.isAssignableFrom(Measurement.class))
+				return measurement;
+			if (clazz.isAssignableFrom(Double.class))
+				return new Double(measurement.getValue());
+			if (clazz.isAssignableFrom(String.class))
+				return measurement.toString();
+		}
+		return null;
+	}
+
+	/**
+	 * generate a random Measurement
+	 * @return
+	 */
+	private Measurement getMeasurement() {
+		long date=System.currentTimeMillis();
+		double value = min + ((max - min) * Math.sin((Math.PI*(date % period))/period));
+		return new Measurement(value, error, unit, date);
+	}
+
+	/**
+	 * @see org.osgi.framework.BundleActivator#start(org.osgi.framework.BundleContext)
+	 */
+	public void start(BundleContext bundleContext) throws Exception {
+		this.bundleContext=bundleContext;
+		
+		configure();
+		
+		Hashtable registrationProperties = new Hashtable();
+		registrationProperties.put(
+			org.osgi.service.wireadmin.WireConstants.WIREADMIN_PRODUCER_FLAVORS,
+			new Class[] { Measurement.class, Double.class, String.class });
+		registrationProperties.put(
+				org.osgi.framework.Constants.SERVICE_PID,
+				this.getClass().getPackage().getName());
+		registrationProperties.put(
+				Unit.class.getName(),
+				UnitUtil.getStringFromUnit(unit));
+		registrationProperties.put(
+				org.osgi.framework.Constants.SERVICE_DESCRIPTION,
+				"a simple Producer that poll Measurement objects");
+
+		serviceRegistration=bundleContext.registerService(Producer.class.getName(), this, registrationProperties);
+
+		quit = false;
+		new Thread(this).start();
+	}
+
+	/**
+	 * @see org.osgi.framework.BundleActivator#stop(org.osgi.framework.BundleContext)
+	 */
+	public void stop(BundleContext bundleContext) throws Exception {
+		this.quit = true;
+		serviceRegistration.unregister();
+	}
+}
\ No newline at end of file

Propchange: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/java/org/apache/felix/sandbox/wireadmin/sample/fictivemeasurementproducer/MeasurementProducer.java
------------------------------------------------------------------------------
    svn:eol-style = native

Added: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/resources/config.properties
URL: http://svn.apache.org/viewvc/felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/resources/config.properties?rev=612292&view=auto
==============================================================================
--- felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/resources/config.properties
(added)
+++ felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/resources/config.properties
Tue Jan 15 15:05:25 2008
@@ -0,0 +1,12 @@
+
+# poll delay
+poll.delay=5000
+
+# measurement parameter for generation
+measurement.max=283.0
+measurement.min=273.0
+measurement.error=0.25
+measurement.unit=K
+
+# period in millisec for sinusoïdal curve 
+measurement.sinusperiod=120000

Propchange: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/main/resources/config.properties
------------------------------------------------------------------------------
    svn:eol-style = native

Added: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/site/readme.html
URL: http://svn.apache.org/viewvc/felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/site/readme.html?rev=612292&view=auto
==============================================================================
--- felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/site/readme.html
(added)
+++ felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/site/readme.html
Tue Jan 15 15:05:25 2008
@@ -0,0 +1,72 @@
+<html>
+<head>
+<title>Fictive Measurement Producer</title>
+</head>
+<body>
+
+<hr width="100%" size="2">
+<h1><i><a name="org.apache.felix.sandbox.wireadmin.sample.fictivemeasurementproducer"></a><font
color="#0000aa">Fictive Measurement Producer</font></i></h1>
+
+<p>
+<b>Description</b><br>
+This bundle provides a simple Producer service which poll fictive Measurement objects (according
a function sine)
+</p>
+
+<p>
+<b>Contributors</b><br>
+Apache Project Team
+</p>
+
+<p>
+<b>License</b><br>
+ASL2<br>
+</p>
+
+<p>
+<b>Services</b><br>
+<code>org.osgi.service.wireadmin.Producer</code>
+</p>
+
+<p>
+<b>Properties</b><br>
+service.pid=org.apache.felix.sandbox.wireadmin.sample.fictivemeasurementproducer<br>
+wireadmin.producer.flavors=class org.osgi.util.measurement.Measurement,class java.lang.String<br>
+<br>
+</p>
+
+<p><b>Requirements</b><br>
+<ul>
+<li>org.osgi.service.wireadmin; version=1.0</li>
+<li>org.osgi.util.measurement; version=1.0</li>
+</ul>
+</p>
+
+
+<hr width="100%" size="2">
+
+
+<p>
+<b>Build</b><br>
+<ol>
+<li>setup the properties in src/main/resources/config.properties</li>
+<li>then build with Maven 2: <code>mvn clean install</code></li>
+</ol>
+</p>
+
+
+<p>
+<b>Tested gateways</b><br>
+<ul>
+<li>Objectweb Oscar (done)</li>
+<li>Apache Felix (done)</li>
+</ul>
+</p>
+
+<p>
+<b>TODO (contributions are welcome)</b><br>
+<ul>
+</ul>
+</p>
+
+</body>
+</html>

Propchange: felix/sandbox/donsez/wireadmin.sample.fictivemeasurementproducer/src/site/readme.html
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message