Create 2.0 M3 release branch

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@785089 13f79535-47bb-0310-9956-ffa450edef68

3 files changed, 292 insertions, 0 deletions

diff --git a/branches/sca-java-2.0-M3/samples/dosgi-calculator/src/test/java/calculator/dosgi/test/CalculatorNode.java b/branches/sca-java-2.0-M3/samples/dosgi-calculator/src/test/java/calculator/dosgi/test/CalculatorNode.java
new file mode 100644
index 0000000000..7f96067764
--- /dev/null
+++ b/branches/sca-java-2.0-M3/samples/dosgi-calculator/src/test/java/calculator/dosgi/test/CalculatorNode.java
@@ -0,0 +1,43 @@
+/*

+ * 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 calculator.dosgi.test;

+

+import org.apache.tuscany.sca.node.equinox.launcher.NodeLauncher;

+

+/**

+ *

+ */

+public class CalculatorNode {

+

+    /**

+     * @param args

+     */

+    public static void main(String[] args) {

+        if (args.length == 0) {

+            args = new String[] {"-bundles"};

+        }

+        try {

+            NodeLauncher.main(args);

+        } catch (Exception e) {

+            e.printStackTrace();

+        }

+    }

+

+}

diff --git a/branches/sca-java-2.0-M3/samples/dosgi-calculator/src/test/java/calculator/dosgi/test/CalculatorOSGiNodeTestCase.java b/branches/sca-java-2.0-M3/samples/dosgi-calculator/src/test/java/calculator/dosgi/test/CalculatorOSGiNodeTestCase.java
new file mode 100644
index 0000000000..d4bede0d98
--- /dev/null
+++ b/branches/sca-java-2.0-M3/samples/dosgi-calculator/src/test/java/calculator/dosgi/test/CalculatorOSGiNodeTestCase.java
@@ -0,0 +1,144 @@
+/*

+ * 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 calculator.dosgi.test;

+

+import static calculator.dosgi.test.OSGiTestUtils.bundleStatus;

+

+import java.io.InputStream;

+import java.io.InputStreamReader;

+import java.io.Reader;

+import java.net.URL;

+

+import org.apache.tuscany.sca.node.equinox.launcher.EquinoxHost;

+import org.junit.AfterClass;

+import org.junit.Assert;

+import org.junit.BeforeClass;

+import org.junit.Test;

+import org.osgi.framework.Bundle;

+import org.osgi.framework.BundleContext;

+import org.osgi.framework.Constants;

+import org.osgi.framework.ServiceReference;

+

+import calculator.dosgi.CalculatorService;

+import calculator.rmi.OperationsRMIServer;

+

+/**

+ *

+ */

+public class CalculatorOSGiNodeTestCase {

+    private static EquinoxHost host;

+    private static BundleContext context;

+    private static Bundle calculatorBundle;

+    private static OperationsRMIServer rmiServer;

+

+    /**

+     * @throws java.lang.Exception

+     */

+    @BeforeClass

+    public static void setUpBeforeClass() throws Exception {

+        try {

+            rmiServer = new OperationsRMIServer();

+            rmiServer.start();

+

+            host = new EquinoxHost();

+            context = host.start();

+

+            for (Bundle b : context.getBundles()) {

+                System.out.println(b);

+                if (b.getSymbolicName().equals("org.eclipse.equinox.ds") || b.getSymbolicName()

+                    .startsWith("org.apache.tuscany.sca.")) {

+                    try {

+                        if (b.getHeaders().get(Constants.FRAGMENT_HOST) == null) {

+                            // Start the non-fragment bundle

+                            b.start();

+                        }

+                    } catch (Exception e) {

+                        e.printStackTrace();

+                    }

+                    System.out.println(bundleStatus(b, false));

+                }

+                if ("calculator.dosgi".equals(b.getSymbolicName())) {

+                    calculatorBundle = b;

+                }

+            }

+

+            if (calculatorBundle != null) {

+                calculatorBundle.start();

+                System.out.println(bundleStatus(calculatorBundle, false));

+            }

+

+        } catch (Exception e) {

+            e.printStackTrace();

+            throw e;

+        }

+    }

+

+    @Test

+    public void testOSGi() {

+        ServiceReference ref =

+            calculatorBundle.getBundleContext().getServiceReference(CalculatorService.class.getName());

+        Assert.assertNotNull(ref);

+        Object service = context.getService(ref);

+        Assert.assertNotNull(service);

+        CalculatorService calculator = OSGiTestUtils.cast(service, CalculatorService.class);

+        System.out.println("2.0 + 1.0 = " + calculator.add(2.0, 1.0));

+        System.out.println("2.0 - 1.0 = " + calculator.subtract(2.0, 1.0));

+        System.out.println("2.0 * 1.0 = " + calculator.multiply(2.0, 1.0));

+        System.out.println("2.0 / 1.0 = " + calculator.divide(2.0, 1.0));

+    }

+

+    @Test

+    /**

+     * Test the Web service exposed by the Calculator

+     */

+    public void testWS() throws Exception {

+        URL url = new URL("http://localhost:8086/CalculatorService?wsdl");

+        InputStream is = url.openStream();

+        Reader reader = new InputStreamReader(is);

+        char[] content = new char[10240]; // 10k

+        int len = 0;

+        while (true) {

+            int size = reader.read(content, len, content.length - len);

+            if (size < 0) {

+                break;

+            }

+            len += size;

+        }

+        Assert.assertTrue(len > 0);

+        String str = new String(content, 0, len);

+        System.out.println(str);

+        Assert.assertTrue(str.indexOf("<wsdl:definitions") != -1);

+    }

+

+    /**

+     * @throws java.lang.Exception

+     */

+    @AfterClass

+    public static void tearDownAfterClass() throws Exception {

+        if (host != null) {

+            host.stop();

+            rmiServer.stop();

+            host = null;

+            rmiServer = null;

+            context = null;

+        }

+    }

+

+}

diff --git a/branches/sca-java-2.0-M3/samples/dosgi-calculator/src/test/java/calculator/dosgi/test/OSGiTestUtils.java b/branches/sca-java-2.0-M3/samples/dosgi-calculator/src/test/java/calculator/dosgi/test/OSGiTestUtils.java
new file mode 100644
index 0000000000..958e744b41
--- /dev/null
+++ b/branches/sca-java-2.0-M3/samples/dosgi-calculator/src/test/java/calculator/dosgi/test/OSGiTestUtils.java
@@ -0,0 +1,105 @@
+/*

+ * 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 calculator.dosgi.test;

+

+import java.lang.reflect.InvocationHandler;

+import java.lang.reflect.Method;

+import java.lang.reflect.Proxy;

+

+import org.osgi.framework.Bundle;

+

+/**

+ *

+ * Utility class to create OSGi bundles

+ *

+ * @version $Rev: 758877 $ $Date: 2009-03-26 14:51:19 -0700 (Thu, 26 Mar 2009) $

+ */

+public class OSGiTestUtils {

+    private static class InvocationHandlerImpl implements InvocationHandler {

+        private Object instance;

+

+        public InvocationHandlerImpl(Object instance) {

+            super();

+            this.instance = instance;

+        }

+

+        public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {

+            Method m = instance.getClass().getMethod(method.getName(), method.getParameterTypes());

+            return m.invoke(instance, args);

+        }

+

+    }

+

+    /**

+     * Returns a string representation of the given bundle.

+     *

+     * @param b

+     * @param verbose

+     * @return

+     */

+    public static String bundleStatus(Bundle bundle, boolean verbose) {

+        StringBuffer sb = new StringBuffer();

+        sb.append(bundle.getBundleId()).append(" ").append(bundle.getSymbolicName());

+        int s = bundle.getState();

+        if ((s & Bundle.UNINSTALLED) != 0) {

+            sb.append(" UNINSTALLED");

+        }

+        if ((s & Bundle.INSTALLED) != 0) {

+            sb.append(" INSTALLED");

+        }

+        if ((s & Bundle.RESOLVED) != 0) {

+            sb.append(" RESOLVED");

+        }

+        if ((s & Bundle.STARTING) != 0) {

+            sb.append(" STARTING");

+        }

+        if ((s & Bundle.STOPPING) != 0) {

+            sb.append(" STOPPING");

+        }

+        if ((s & Bundle.ACTIVE) != 0) {

+            sb.append(" ACTIVE");

+        }

+

+        if (verbose) {

+            sb.append(" ").append(bundle.getLocation());

+            sb.append(" ").append(bundle.getHeaders());

+        }

+        return sb.toString();

+    }

+

+    /**

+     * A utility to cast the object to the given interface. If the class for the object

+     * is loaded by a different classloader, a proxy will be created.

+     *

+     * @param <T>

+     * @param obj

+     * @param cls

+     * @return

+     */

+    public static <T> T cast(Object obj, Class<T> cls) {

+        if (cls.isInstance(obj)) {

+            return cls.cast(obj);

+        } else {

+            return cls.cast(Proxy.newProxyInstance(cls.getClassLoader(),

+                                                   new Class<?>[] {cls},

+                                                   new InvocationHandlerImpl(obj)));

+        }

+    }

+}