summaryrefslogtreecommitdiffstats
path: root/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test
diff options
context:
space:
mode:
Diffstat (limited to 'branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test')
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/AtomTuple.java30
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxInterface.java65
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java97
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ModuleInterface.java31
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java924
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponent.java27
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponentImpl.java110
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceInterface.java45
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponent.java40
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImpl.java48
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplClone.java48
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplTimeout.java65
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/SmallTuple.java35
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/StructuredTuple.java37
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnorableRunner.java139
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnoreTest.java29
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/resources/ErlangReference.composite58
-rw-r--r--branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/resources/ErlangService.composite54
18 files changed, 0 insertions, 1882 deletions
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/AtomTuple.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/AtomTuple.java
deleted file mode 100644
index f0930295a7..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/AtomTuple.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-import org.apache.tuscany.sca.binding.erlang.meta.ErlangAtom;
-
-public class AtomTuple {
-
- @ErlangAtom
- public String field1;
- public int field2;
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxInterface.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxInterface.java
deleted file mode 100644
index 034abab8f3..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxInterface.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-import org.apache.tuscany.sca.binding.erlang.meta.ErlangAtom;
-
-/**
- * @version $Rev$ $Date$
- */
-public interface MboxInterface {
-
- String sendArgs(String arg) throws Exception;
-
- boolean sendArgs(boolean arg) throws Exception;
-
- float sendArgs(float arg) throws Exception;
-
- double sendArgs(double arg) throws Exception;
-
- long sendArgs(long arg) throws Exception;
-
- int sendArgs(int arg) throws Exception;
-
- char sendArgs(char arg) throws Exception;
-
- short sendArgs(short arg) throws Exception;
-
- byte sendArgs(byte arg) throws Exception;
-
- void sendArgs(int arg1, String arg2) throws Exception;
-
- StructuredTuple sendArgs(StructuredTuple arg) throws Exception;
-
- String[] sendArgs(String[] arg) throws Exception;
-
- String[][] sendArgs(String[][] arg);
-
- byte[] sendArgs(byte[] arg);
-
- @ErlangAtom
- String[] sendArgs(@ErlangAtom String arg1, AtomTuple arg2);
-
- @ErlangAtom
- String[][] sendArgs(@ErlangAtom String[][] arg1, int arg2);
-
- void sendArgs() throws Exception;
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java
deleted file mode 100644
index 0cab5c0b0e..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/MboxListener.java
+++ /dev/null
@@ -1,97 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-import java.lang.annotation.Annotation;
-
-import org.apache.tuscany.sca.binding.erlang.impl.types.TypeHelpersProxy;
-
-import com.ericsson.otp.erlang.OtpErlangObject;
-import com.ericsson.otp.erlang.OtpErlangPid;
-import com.ericsson.otp.erlang.OtpErlangTuple;
-import com.ericsson.otp.erlang.OtpMbox;
-import com.ericsson.otp.erlang.OtpMsg;
-
-/**
- * @version $Rev$ $Date$
- */
-public class MboxListener implements Runnable {
-
- private OtpMbox mbox;
- private OtpMsg msg;
- private Object response;
- private long duration;
-
- public MboxListener(OtpMbox mbox, Object response) {
- this(mbox, response, 0);
- }
-
- public MboxListener(OtpMbox mbox, Object response, long duration) {
- this.mbox = mbox;
- this.response = response;
- this.duration = duration;
- }
-
- public void run() {
- try {
- msg = mbox.receiveMsg();
- Thread.sleep(duration);
- OtpErlangPid senderPid = null;
- if (response != null) {
- if (msg.getMsg().getClass().equals(OtpErlangTuple.class)
- && ((OtpErlangTuple) msg.getMsg()).elementAt(0)
- .getClass().equals(OtpErlangPid.class)) {
- senderPid = (OtpErlangPid) ((OtpErlangTuple) msg.getMsg())
- .elementAt(0);
- } else {
- senderPid = msg.getSenderPid();
- }
- mbox.send(senderPid, TypeHelpersProxy.toErlang(response,
- new Annotation[0]));
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
- public OtpErlangObject getMsg() {
- try {
- // Sometimes clients tries to get message which isn't fully
- // received.
- // If so - give it more tries. This sometimes caused
- // NullPointerException in
- // ReferenceServiceTestCase.testMultipleArguments().
- for (int i = 0; i < 3; i++) {
- if (msg != null) {
- return ((OtpErlangTuple) msg.getMsg()).elementAt(1);
- } else {
- try {
- Thread.sleep(100);
- } catch (InterruptedException e) {
- }
- }
- }
- return ((OtpErlangTuple) msg.getMsg()).elementAt(1);
- } catch (Exception e) {
- e.printStackTrace();
- }
- return null;
- }
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ModuleInterface.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ModuleInterface.java
deleted file mode 100644
index 6fc95ac120..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ModuleInterface.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-/**
- * @version $Rev$ $Date$
- */
-public interface ModuleInterface {
-
- String start(String arg1, String arg2) throws Exception;
-
- String start() throws Exception;
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java
deleted file mode 100644
index 2073e4b154..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceServiceTestCase.java
+++ /dev/null
@@ -1,924 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.fail;
-
-import java.io.IOException;
-
-import org.apache.tuscany.sca.binding.erlang.impl.TypeMismatchException;
-import org.apache.tuscany.sca.binding.erlang.impl.exceptions.ErlangException;
-import org.apache.tuscany.sca.binding.erlang.testing.dynaignore.IgnorableRunner;
-import org.apache.tuscany.sca.binding.erlang.testing.dynaignore.IgnoreTest;
-import org.apache.tuscany.sca.host.embedded.SCADomain;
-import org.junit.AfterClass;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-
-import com.ericsson.otp.erlang.OtpAuthException;
-import com.ericsson.otp.erlang.OtpConnection;
-import com.ericsson.otp.erlang.OtpErlangAtom;
-import com.ericsson.otp.erlang.OtpErlangBinary;
-import com.ericsson.otp.erlang.OtpErlangBoolean;
-import com.ericsson.otp.erlang.OtpErlangDouble;
-import com.ericsson.otp.erlang.OtpErlangInt;
-import com.ericsson.otp.erlang.OtpErlangList;
-import com.ericsson.otp.erlang.OtpErlangLong;
-import com.ericsson.otp.erlang.OtpErlangObject;
-import com.ericsson.otp.erlang.OtpErlangString;
-import com.ericsson.otp.erlang.OtpErlangTuple;
-import com.ericsson.otp.erlang.OtpMbox;
-import com.ericsson.otp.erlang.OtpNode;
-import com.ericsson.otp.erlang.OtpPeer;
-import com.ericsson.otp.erlang.OtpSelf;
-
-/**
- * Test is annotated with test runner, which will ignore tests if epmd is not
- * available
- *
- * @version $Rev$ $Date$
- */
-@RunWith(IgnorableRunner.class)
-public class ReferenceServiceTestCase {
-
- private static final String EPMD_COMMAND = "epmd";
-
- private static MboxInterface mboxReference;
- private static MboxInterface timeoutMboxReference;
- private static ServiceInterface moduleReference;
- private static ServiceInterface cookieModuleReference;
- private static ServiceInterface invalidCookieModuleReference;
- private static ServiceInterface timeoutModuleReference;
- private static OtpNode serNode;
- private static OtpMbox serMbox;
- private static OtpNode refNode;
- private static OtpMbox refMbox;
- private static Process epmdProcess;
-
- @BeforeClass
- public static void init() throws IOException {
- try {
- epmdProcess = Runtime.getRuntime().exec(EPMD_COMMAND);
- SCADomain domain = SCADomain
- .newInstance("ErlangReference.composite");
- SCADomain.newInstance("ErlangService.composite");
- ReferenceTestComponentImpl component = domain.getService(
- ReferenceTestComponentImpl.class, "ReferenceTest");
-
- mboxReference = component.getMboxReference();
- timeoutMboxReference = component.getTimeoutMboxReference();
- moduleReference = component.getModuleReference();
- cookieModuleReference = component.getCookieModuleReference();
- invalidCookieModuleReference = component
- .getInvalidCookieModuleReference();
- timeoutModuleReference = component.getTimeoutModuleReference();
-
- serNode = new OtpNode("MboxServer");
- serMbox = serNode.createMbox("sendArgs");
- refNode = new OtpNode("MboxClient");
- refMbox = refNode.createMbox("connector_to_SCA_mbox");
- } catch (IOException e) {
- System.out.println("Problem executing " + EPMD_COMMAND + ": "
- + e.getLocalizedMessage() + ". Tests will be IGNORED.");
- }
- }
-
- @AfterClass
- public static void clean() {
- if (epmdProcess != null) {
- epmdProcess.destroy();
- }
- }
-
- @Before
- public void before() {
- if (epmdProcess == null) {
- throw new IgnoreTest();
- }
- }
-
- /**
- * Tests passing strings
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testStrings() throws Exception {
- String strArg = "Test message";
- String strResult = "OK";
- MboxListener mboxListener = new MboxListener(serMbox, strResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- String testResult = mboxReference.sendArgs(strArg);
- assertEquals(strArg, ((OtpErlangString) mboxListener.getMsg())
- .stringValue());
- assertEquals(strResult, testResult);
- }
-
- /**
- * Tests passing booleans
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testBooleans() throws Exception {
- boolean booleanArg = true;
- boolean booleanResult = false;
- MboxListener mboxListener = new MboxListener(serMbox, booleanResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- boolean testResult = mboxReference.sendArgs(booleanArg);
- assertEquals(booleanArg, ((OtpErlangAtom) mboxListener.getMsg())
- .booleanValue());
- assertEquals(booleanResult, testResult);
- }
-
- /**
- * Tests passing floats
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testFloats() throws Exception {
- float floatArg = 1.0f;
- float floatResult = 2.0f;
- MboxListener mboxListener = new MboxListener(serMbox, floatResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- float testResult = mboxReference.sendArgs(floatArg);
- assertEquals(floatArg, ((OtpErlangDouble) mboxListener.getMsg())
- .doubleValue(), 0);
- assertEquals(floatResult, testResult, 0);
- }
-
- /**
- * Tests passing doubles
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testDoubles() throws Exception {
- double doubleArg = 1.0f;
- double doubleResult = 2.0f;
- MboxListener mboxListener = new MboxListener(serMbox, doubleResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- double testResult = mboxReference.sendArgs(doubleArg);
- assertEquals(doubleArg, ((OtpErlangDouble) mboxListener.getMsg())
- .doubleValue(), 0);
- assertEquals(doubleResult, testResult, 0);
- }
-
- /**
- * Tests passing long values
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testLongs() throws Exception {
- long longArg = 1;
- long longResult = 2;
- MboxListener mboxListener = new MboxListener(serMbox, longResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- long testResult = mboxReference.sendArgs(longArg);
- assertEquals(longArg, ((OtpErlangLong) mboxListener.getMsg())
- .longValue(), 0);
- assertEquals(longResult, testResult, 0);
- }
-
- /**
- * Tests passing integers
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testInts() throws Exception {
- int intArg = 1;
- int intResult = 2;
- MboxListener mboxListener = new MboxListener(serMbox, intResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- int testResult = mboxReference.sendArgs(intArg);
- assertEquals(intArg,
- ((OtpErlangLong) mboxListener.getMsg()).intValue(), 0);
- assertEquals(intResult, testResult, 0);
- }
-
- /**
- * Tests passing chars
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testChars() throws Exception {
- char charArg = 1;
- char charResult = 2;
- MboxListener mboxListener = new MboxListener(serMbox, charResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- char testResult = mboxReference.sendArgs(charArg);
- assertEquals(charArg, ((OtpErlangLong) mboxListener.getMsg())
- .charValue(), 0);
- assertEquals(charResult, testResult, 0);
- }
-
- /**
- * Tests passing shorts
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testShorts() throws Exception {
- short shortArg = 1;
- short shortResult = 2;
- MboxListener mboxListener = new MboxListener(serMbox, shortResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- short testResult = mboxReference.sendArgs(shortArg);
- assertEquals(shortArg, ((OtpErlangLong) mboxListener.getMsg())
- .shortValue(), 0);
- assertEquals(shortResult, testResult, 0);
- }
-
- /**
- * Tests passing bytes
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testBytes() throws Exception {
- byte byteArg = 1;
- byte byteResult = 2;
- MboxListener mboxListener = new MboxListener(serMbox, byteResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- byte testResult = mboxReference.sendArgs(byteArg);
- assertEquals(byteArg, ((OtpErlangLong) mboxListener.getMsg())
- .byteValue(), 0);
- assertEquals(byteResult, testResult, 0);
- }
-
- /**
- * Tests passing multiple arguments
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testMultipleArguments() throws Exception {
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- String testString = "TupleString";
- int testInt = 10;
- mboxReference.sendArgs(testInt, testString);
- // FIXME:
- // without following sleep an exception occurs:
- // com.ericsson.otp.erlang.OtpErlangDecodeException: Cannot read from
- // input stream
- Thread.sleep(100);
- assertEquals(testInt, ((OtpErlangLong) ((OtpErlangTuple) mboxListener
- .getMsg()).elementAt(0)).longValue());
- assertEquals(testString,
- ((OtpErlangString) ((OtpErlangTuple) mboxListener.getMsg())
- .elementAt(1)).stringValue());
- }
-
- /**
- * Tests passing tuples
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testTuples() throws Exception {
- StructuredTuple tupleResult = new StructuredTuple();
- tupleResult.arg1.arg1 = 1;
- tupleResult.arg1.arg2 = "Tuple inside tuple";
- tupleResult.arg2 = "Tuple!";
- tupleResult.arg3 = true;
- MboxListener mboxListener = new MboxListener(serMbox, tupleResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- StructuredTuple testArg = new StructuredTuple();
- testArg.arg2 = "Arg2a";
- testArg.arg3 = true;
- testArg.arg1.arg1 = 10;
- testArg.arg1.arg2 = "Arg2b";
- StructuredTuple testResult = mboxReference.sendArgs(testArg);
- assertEquals(tupleResult, testResult);
- OtpErlangTuple received = (OtpErlangTuple) mboxListener.getMsg();
- assertEquals(testArg.arg1.arg1,
- ((OtpErlangLong) ((OtpErlangTuple) received.elementAt(0))
- .elementAt(0)).longValue());
- assertEquals(testArg.arg1.arg2,
- ((OtpErlangString) ((OtpErlangTuple) received.elementAt(0))
- .elementAt(1)).stringValue());
- assertEquals(testArg.arg2, ((OtpErlangString) received.elementAt(1))
- .stringValue());
- assertEquals(testArg.arg3, ((OtpErlangAtom) received.elementAt(2))
- .booleanValue());
- }
-
- /**
- * Test passing Erlang binaries
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testBinaries() throws Exception {
- byte[] testArg = { 0, 1 };
- MboxListener mboxListener = new MboxListener(serMbox, testArg);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- byte[] testResult = mboxReference.sendArgs(testArg);
- assertEquals(testArg.length, testResult.length);
- for (int i = 0; i < testArg.length; i++) {
- assertEquals(testArg[i], testResult[i]);
- }
- OtpErlangBinary received = (OtpErlangBinary) mboxListener.getMsg();
- assertEquals(testArg.length, received.size());
- for (int i = 0; i < testArg.length; i++) {
- assertEquals(testArg[i], received.binaryValue()[i]);
- }
- }
-
- /**
- * Tests passing lists
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testLists() throws Exception {
- String[] testArg = new String[] { "One", "Two", "Three" };
- MboxListener mboxListener = new MboxListener(serMbox, testArg);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- String[] testResult = mboxReference.sendArgs(testArg);
- assertEquals(testArg.length, testResult.length);
- for (int i = 0; i < testArg.length; i++) {
- assertEquals(testArg[i], testResult[i]);
- }
- OtpErlangList received = (OtpErlangList) mboxListener.getMsg();
- assertEquals(testArg.length, received.arity());
- for (int i = 0; i < testArg.length; i++) {
- assertEquals(testArg[i], ((OtpErlangString) received.elementAt(i))
- .stringValue());
- }
- }
-
- /**
- * Tests passing multidimensional lists
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testMultiDimLists() throws Exception {
- String[][] testArg = new String[][] { { "One", "Two" },
- { "Three", "Four", "Five" }, { "Six" } };
- MboxListener mboxListener = new MboxListener(serMbox, testArg);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- String[][] testResult = mboxReference.sendArgs(testArg);
- assertEquals(testArg.length, testResult.length);
- for (int i = 0; i < testArg.length; i++) {
- for (int j = 0; j < testArg[i].length; j++) {
- assertEquals(testArg[i][j], testResult[i][j]);
- }
- }
- OtpErlangList received = (OtpErlangList) mboxListener.getMsg();
- assertEquals(testArg.length, received.arity());
- for (int i = 0; i < testArg.length; i++) {
- for (int j = 0; j < testArg[i].length; j++) {
- assertEquals(testArg[i][j],
- (((OtpErlangString) ((OtpErlangList) received
- .elementAt(i)).elementAt(j)).stringValue()));
- }
- }
- }
-
- /**
- * Tests passing Erlang atoms. It provides cases for annotating result
- * types, parameters and fields in java classes - tuples.
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testAtoms() throws Exception {
- AtomTuple arg2 = new AtomTuple();
- arg2.field1 = "test";
- String arg1 = "First arg";
- String[] strResult = { "Hello", "World" };
- MboxListener mboxListener = new MboxListener(serMbox, strResult);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- String[] testResult = mboxReference.sendArgs(arg1, arg2);
- assertEquals(strResult[0], testResult[0]);
- assertEquals(strResult[1], testResult[1]);
-
- assertEquals(arg1, ((OtpErlangAtom) ((OtpErlangTuple) mboxListener
- .getMsg()).elementAt(0)).atomValue());
-
- assertEquals(
- arg2.field1,
- ((OtpErlangAtom) ((OtpErlangTuple) ((OtpErlangTuple) mboxListener
- .getMsg()).elementAt(1)).elementAt(0)).atomValue());
-
- // test multi dimensional arrays
- String[][] arg = { { "this", "is" }, { "a" }, { "test" } };
- mboxListener = new MboxListener(serMbox, arg);
- mboxThread = new Thread(mboxListener);
- mboxThread.start();
- String[][] multiDimRes = mboxReference.sendArgs(arg, 1);
- for (int i = 0; i < arg.length; i++) {
- for (int j = 0; j < arg[i].length; j++) {
- assertEquals(arg[i][j], multiDimRes[i][j]);
- assertEquals(
- arg[i][j],
- ((OtpErlangAtom) ((OtpErlangList) ((OtpErlangList) ((OtpErlangTuple) mboxListener
- .getMsg()).elementAt(0)).elementAt(i))
- .elementAt(j)).atomValue());
- }
- }
-
- }
-
- /**
- * Tests Erlang Atom types on service side
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testServiceAtoms() throws Exception {
- String[] args = { "Say", "Atoms" };
- OtpErlangObject[] toList = new OtpErlangObject[2];
- toList[0] = new OtpErlangString(args[0]);
- toList[1] = new OtpErlangString(args[1]);
- OtpErlangList list = new OtpErlangList(toList);
- OtpErlangObject[] toTuple = new OtpErlangObject[2];
- toTuple[0] = refMbox.self();
- toTuple[1] = list;
- refMbox.send("sayAtoms", "RPCServerMbox", new OtpErlangTuple(toTuple));
- OtpErlangObject result = refMbox.receiveMsg().getMsg();
- assertEquals(args.length, ((OtpErlangList) result).arity());
- for (int i = 0; i < args.length; i++) {
- assertEquals(args[i], ((OtpErlangAtom) ((OtpErlangList) result)
- .elementAt(i)).atomValue());
- }
- }
-
- /**
- * Tests mismatched interface
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void typeMismatch() throws Exception {
- try {
- StructuredTuple arg = new StructuredTuple();
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- String[] arg = new String[] { "test" };
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- long arg = 1;
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- int arg = 1;
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- short arg = 1;
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- char arg = 1;
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- byte arg = 1;
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- double arg = 1;
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- float arg = 1;
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- String arg = "1";
- MboxListener mboxListener = new MboxListener(serMbox, true);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
-
- try {
- boolean arg = true;
- MboxListener mboxListener = new MboxListener(serMbox, 1);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- mboxReference.sendArgs(arg);
- } catch (Exception e) {
- assertEquals(TypeMismatchException.class, e.getClass());
- System.out.println(e.getMessage());
- }
- }
-
- /**
- * Basic RPC test, without arguments
- *
- * @throws Exception
- */
- @Test(timeout = 10000000)
- public void testRPC() throws Exception {
- String[] result = moduleReference.sayHellos();
- assertEquals(2, result.length);
- assertEquals("1", result[0]);
- assertEquals("2", result[1]);
- }
-
- /**
- * Tests RPC with arguments
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testRPCWithArgs() throws Exception {
- String arg1 = "One";
- String arg2 = "Two";
- String testResult = moduleReference.sayHello(arg1, arg2);
- assertEquals("Hello " + arg1 + " " + arg2, testResult);
- }
-
- /**
- * Tests RPC with structured arguments
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testRPCWithComplexArgs() throws Exception {
- StructuredTuple arg = new StructuredTuple();
- arg.arg1.arg2 = "Not empty";
- arg.arg2 = "Not empty";
- StructuredTuple testResult = moduleReference.passComplexArgs(arg,
- new String[] { "some", "array" });
- assertEquals(arg, testResult);
- }
-
- /**
- * Tests RPC with no result
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testRPCWithVoidResult() throws Exception {
- moduleReference.doNothing();
- }
-
- /**
- * Tests handling requests pointing to unknown functions
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testUnknownFunction() throws Exception {
-
- // following functions differs by parameters
-
- try {
- moduleReference.sayHello();
- } catch (Exception e) {
- assertEquals(ErlangException.class, e.getClass());
- }
-
- try {
- moduleReference.sayHello("1");
- } catch (Exception e) {
- assertEquals(ErlangException.class, e.getClass());
- }
-
- try {
- moduleReference.sayHello(1, 2);
- } catch (Exception e) {
- assertEquals(ErlangException.class, e.getClass());
- }
-
- // for following ones name not exists
-
- moduleReference.notExist();
-
- try {
- moduleReference.notExistWithException();
- } catch (Exception e) {
- assertEquals(ErlangException.class, e.getClass());
- }
- }
-
- /**
- * Tests mbox with retrieving and answering with basic arguments
- *
- * @throws Exception
- */
- @Test(timeout = 2000)
- public void testMbox() throws Exception {
- OtpErlangObject[] args = new OtpErlangObject[2];
- args[0] = new OtpErlangString("world");
- args[1] = new OtpErlangString("!");
- OtpErlangTuple tuple = new OtpErlangTuple(args);
- OtpErlangObject[] argsWithSender = new OtpErlangObject[2];
- argsWithSender[0] = refMbox.self();
- argsWithSender[1] = tuple;
- refMbox.send("sayHello", "RPCServerMbox", new OtpErlangTuple(
- argsWithSender));
- OtpErlangString result = (OtpErlangString) refMbox.receiveMsg()
- .getMsg();
- assertEquals("Hello world !", result.stringValue());
- }
-
- /**
- * Tests receiving reply without sending self PID
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testMsgWithoutPid() throws Exception {
- OtpErlangObject[] args = new OtpErlangObject[2];
- args[0] = new OtpErlangString("world");
- args[1] = new OtpErlangString("!");
- refMbox.send("sayHello", "RPCServerMbox", new OtpErlangTuple(args));
- OtpErlangString result = (OtpErlangString) refMbox.receiveMsg()
- .getMsg();
- assertEquals("Hello world !", result.stringValue());
- }
-
- /**
- * Tests service mbox receiving complex message
- *
- * @throws Exception
- */
- @Test(timeout = 2000)
- public void testMboxWithComplexArgs() throws Exception {
- int arg1 = 1;
- String arg2 = "arg2";
- String arg3 = "arg3";
- boolean arg4 = true;
-
- OtpErlangObject[] smallTupleContent = new OtpErlangObject[2];
- smallTupleContent[0] = new OtpErlangInt(arg1);
- smallTupleContent[1] = new OtpErlangString(arg2);
- OtpErlangTuple smallTuple = new OtpErlangTuple(smallTupleContent);
- OtpErlangObject[] structuredTupleContent = new OtpErlangObject[3];
- structuredTupleContent[0] = smallTuple;
- structuredTupleContent[1] = new OtpErlangString(arg3);
- structuredTupleContent[2] = new OtpErlangBoolean(arg4);
- OtpErlangTuple structuredTuple = new OtpErlangTuple(
- structuredTupleContent);
- OtpErlangObject[] secondArg = new OtpErlangObject[2];
- secondArg[0] = new OtpErlangString("in");
- secondArg[1] = new OtpErlangString("array");
- OtpErlangList list = new OtpErlangList(secondArg);
- OtpErlangObject[] argsContent = new OtpErlangObject[2];
- argsContent[0] = structuredTuple;
- argsContent[1] = list;
- OtpErlangTuple args = new OtpErlangTuple(argsContent);
- OtpErlangObject[] withSender = new OtpErlangObject[2];
- withSender[0] = refMbox.self();
- withSender[1] = args;
- refMbox.send("passComplexArgs", "RPCServerMbox", new OtpErlangTuple(
- withSender));
- OtpErlangObject result = refMbox.receiveMsg().getMsg();
- assertEquals(arg1,
- ((OtpErlangLong) ((OtpErlangTuple) ((OtpErlangTuple) result)
- .elementAt(0)).elementAt(0)).intValue());
- assertEquals(arg2,
- ((OtpErlangString) ((OtpErlangTuple) ((OtpErlangTuple) result)
- .elementAt(0)).elementAt(1)).stringValue());
- assertEquals(arg3, ((OtpErlangString) ((OtpErlangTuple) result)
- .elementAt(1)).stringValue());
- assertEquals(arg4, ((OtpErlangAtom) ((OtpErlangTuple) result)
- .elementAt(2)).booleanValue());
- }
-
- /**
- * Tests timeout feature for reference binding messaging
- *
- * @throws Exception
- */
- @Test(timeout = 4000)
- public void testMboxReferenceTimeouts() throws Exception {
- long timeBiggerThanTimeout = 1000;
- String stringResult = "result";
-
- // doing test for response time bigger than declared timeout (500)
- MboxListener mboxListener = new MboxListener(serMbox, stringResult,
- timeBiggerThanTimeout);
- Thread mboxThread = new Thread(mboxListener);
- mboxThread.start();
- try {
- // timeout exception expected
- timeoutMboxReference.sendArgs("");
- fail("Exception expected");
- } catch (Exception e) {
- assertEquals(ErlangException.class, e.getClass());
- assertEquals(e.getCause().getClass(), InterruptedException.class);
- }
-
- // doing test for response time smaller than declared timeout (500)
- mboxListener = new MboxListener(serMbox, stringResult, 0);
- mboxThread = new Thread(mboxListener);
- mboxThread.start();
- // expecting no timeout exception
- String testResult = timeoutMboxReference.sendArgs("");
- assertEquals(stringResult, testResult);
-
- // doing test for response time which will cause timeout. This time
- // there is no declared exception in users operation so we expect no
- // exception and null result
- mboxListener = new MboxListener(serMbox, new byte[1],
- timeBiggerThanTimeout);
- mboxThread = new Thread(mboxListener);
- mboxThread.start();
- // expecting no timeout exception
- byte[] result = timeoutMboxReference.sendArgs(new byte[1]);
- assertEquals(null, result);
- }
-
- /**
- * Tests timeout feature for reference binding RPC
- *
- * @throws Exception
- */
- @Test(timeout = 4000)
- public void testRpcReferenceTimeouts() throws Exception {
-
- // doing test for response time which will cause timeout. Method does
- // not
- // declare exception so only null value will be returned
- String result1 = timeoutModuleReference.sayHello("hello", "world");
- assertEquals(null, result1);
-
- // doing test for response time which will cause timeout. Method declare
- // exception, so expecting one
- try {
- timeoutModuleReference.sayHellos();
- fail("Exception expected");
- } catch (Exception e) {
- assertEquals(ErlangException.class, e.getClass());
- }
-
- // doing test for response time shorter than timeout
- timeoutModuleReference.doNothing();
- }
-
- /**
- * Tests timeout feature for service side bindings
- *
- * @throws Exception
- */
- @Test(timeout = 4000)
- public void testServiceTimeouts() throws Exception {
- OtpSelf self = new OtpSelf("tmp_connector_"
- + System.currentTimeMillis());
- OtpPeer peer = new OtpPeer("RPCServerTimeout");
- OtpConnection connection = self.connect(peer);
- // delay message sending after connecting
- Thread.sleep(1000);
- // service binding timeout set to 500 so after that time it will give up
- // and close connection
- try {
- connection.send("rex", new OtpErlangString("test"));
- fail("Exception expected");
- } catch (Exception e) {
- assertEquals(IOException.class, e.getClass());
- }
-
- connection = self.connect(peer);
- // sending message immediately and encountering no connection close
- connection.send("rex", new OtpErlangString("test"));
-
- }
-
- /**
- * Tests cookie feature for both reference and service bindings RPC
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testReferenceCookies() throws Exception {
- // testing wrong cookie
- try {
- invalidCookieModuleReference.sayHellos();
- fail("Exception expected");
- } catch (Exception e) {
- assertEquals(ErlangException.class, e.getClass());
- assertEquals(OtpAuthException.class, e.getCause().getClass());
- }
-
- // testing correct cookie
- cookieModuleReference.sayHellos();
- }
-
- /**
- * Tests fix which allow to send message with no user specified content (in
- * fact always will be some content - senders PID at the content beginning).
- *
- * @throws Exception
- */
- @Test(timeout = 1000)
- public void testMboxNoArgs() throws Exception {
- mboxReference.sendArgs();
- // no exception should occur
- }
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponent.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponent.java
deleted file mode 100644
index be43820b0b..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponent.java
+++ /dev/null
@@ -1,27 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-/**
- * @version $Rev$ $Date$
- */
-public interface ReferenceTestComponent {
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponentImpl.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponentImpl.java
deleted file mode 100644
index 7bcc378b78..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ReferenceTestComponentImpl.java
+++ /dev/null
@@ -1,110 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-import org.osoa.sca.annotations.Reference;
-
-/**
- * @version $Rev$ $Date$
- */
-public class ReferenceTestComponentImpl implements ReferenceTestComponent {
-
- private MboxInterface mboxReference;
- private MboxInterface timeoutMboxReference;
- private MboxInterface cookieMboxReference;
- private ServiceInterface moduleReference;
- private ServiceInterface cookieModuleReference;
- private ServiceInterface invalidCookieModuleReference;
- private ServiceInterface timeoutModuleReference;
- private ServiceInterface clonedModuleReference;
-
- @Reference
- public void setMboxReference(MboxInterface mboxReference) {
- this.mboxReference = mboxReference;
- }
-
- @Reference
- public void setTimeoutMboxReference(MboxInterface timeoutMboxReference) {
- this.timeoutMboxReference = timeoutMboxReference;
- }
-
- @Reference
- public void setCookieMboxReference(MboxInterface cookieMboxReference) {
- this.cookieMboxReference = cookieMboxReference;
- }
-
- @Reference
- public void setModuleReference(ServiceInterface timeoutModuleReference) {
- this.moduleReference = timeoutModuleReference;
- }
-
- @Reference
- public void setCookieModuleReference(ServiceInterface cookieModuleReference) {
- this.cookieModuleReference = cookieModuleReference;
- }
-
- @Reference
- public void setInvalidCookieModuleReference(ServiceInterface invalidCookieModuleReference) {
- this.invalidCookieModuleReference = invalidCookieModuleReference;
- }
-
- @Reference
- public void setTimeoutModuleReference(ServiceInterface timeoutModuleReference) {
- this.timeoutModuleReference = timeoutModuleReference;
- }
-
- @Reference
- public void setClonedModuleReference(ServiceInterface clonedModuleReference) {
- this.clonedModuleReference = clonedModuleReference;
- }
-
- public MboxInterface getMboxReference() {
- return mboxReference;
- }
-
- public MboxInterface getTimeoutMboxReference() {
- return timeoutMboxReference;
- }
-
- public MboxInterface getCookieMboxReference() {
- return cookieMboxReference;
- }
-
- public ServiceInterface getModuleReference() {
- return moduleReference;
- }
-
- public ServiceInterface getCookieModuleReference() {
- return cookieModuleReference;
- }
-
- public ServiceInterface getInvalidCookieModuleReference() {
- return invalidCookieModuleReference;
- }
-
- public ServiceInterface getTimeoutModuleReference() {
- return timeoutModuleReference;
- }
-
- public ServiceInterface getClonedModuleReference() {
- return clonedModuleReference;
- }
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceInterface.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceInterface.java
deleted file mode 100644
index 244e6f7f40..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceInterface.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-/**
- * @version $Rev$ $Date$
- */
-public interface ServiceInterface {
-
- void doNothing();
-
- String sayHello(String arg1, String arg2);
-
- String[] sayHellos() throws Exception;
-
- StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2);
-
- String sayHello() throws Exception;
-
- String sayHello(String arg) throws Exception;
-
- String sayHello(int arg1, int arg2);
-
- void notExistWithException() throws Exception;
-
- void notExist();
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponent.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponent.java
deleted file mode 100644
index 7cc1fe4dc1..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponent.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-import org.apache.tuscany.sca.binding.erlang.meta.ErlangAtom;
-
-/**
- * @version $Rev$ $Date$
- */
-public interface ServiceTestComponent {
-
- String sayHello(String arg1, String arg2);
-
- String[] sayHellos() throws Exception;
-
- @ErlangAtom
- String[] sayAtoms(@ErlangAtom String[] arg);
-
- StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2);
-
- void doNothing();
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImpl.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImpl.java
deleted file mode 100644
index b3f39fecd4..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImpl.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-/**
- * @version $Rev$ $Date$
- */
-public class ServiceTestComponentImpl implements ServiceTestComponent {
-
- public String sayHello(String arg1, String arg2) {
- return "Hello " + arg1 + " " + arg2;
- }
-
- public String[] sayHellos() {
- String[] result = new String[] { "1", "2" };
- return result;
- }
-
- public StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2) {
- return arg1;
- }
-
- public void doNothing() {
- // doing nothing
- }
-
- public String[] sayAtoms(String[] arg) {
- return arg;
- }
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplClone.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplClone.java
deleted file mode 100644
index 735cefe53d..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplClone.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-/**
- * @version $Rev$ $Date$
- */
-public class ServiceTestComponentImplClone implements ServiceTestComponent {
-
- public String sayHello(String arg1, String arg2) {
- return "Bye " + arg1 + " " + arg2;
- }
-
- public String[] sayHellos() {
- String[] result = new String[] { "-1", "-2" };
- return result;
- }
-
- public StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2) {
- return arg1;
- }
-
- public void doNothing() {
-
- }
-
- public String[] sayAtoms(String[] arg) {
- return arg;
- }
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplTimeout.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplTimeout.java
deleted file mode 100644
index 40a9f96769..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ServiceTestComponentImplTimeout.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-/**
- * @version $Rev$ $Date$
- */
-public class ServiceTestComponentImplTimeout implements ServiceTestComponent {
-
- private long duration = 1000;
-
- public String sayHello(String arg1, String arg2) {
- try {
- Thread.sleep(duration);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- return "Bye " + arg1 + " " + arg2;
- }
-
- public String[] sayHellos() {
- try {
- Thread.sleep(duration);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- String[] result = new String[] { "-1", "-2" };
- return result;
- }
-
- public StructuredTuple passComplexArgs(StructuredTuple arg1, String[] arg2) {
- try {
- Thread.sleep(duration);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- return arg1;
- }
-
- public void doNothing() {
-
- }
-
- public String[] sayAtoms(String[] arg) {
- return arg;
- }
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/SmallTuple.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/SmallTuple.java
deleted file mode 100644
index ac8b9e426a..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/SmallTuple.java
+++ /dev/null
@@ -1,35 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-/**
- * @version $Rev$ $Date$
- */
-public class SmallTuple {
-
- public int arg1;
- public String arg2 = "";
-
- public boolean equals(Object o) {
- SmallTuple comp = (SmallTuple) o;
- return arg1 == comp.arg1 && arg2.equals(arg2);
- }
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/StructuredTuple.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/StructuredTuple.java
deleted file mode 100644
index 193654172f..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/StructuredTuple.java
+++ /dev/null
@@ -1,37 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing;
-
-/**
- * @version $Rev$ $Date$
- */
-public class StructuredTuple {
-
- public SmallTuple arg1 = new SmallTuple();
- public String arg2 = "";
- public boolean arg3;
-
- public boolean equals(Object o) {
- StructuredTuple comp = (StructuredTuple) o;
- return arg2.equals(comp.arg2) && arg3 == comp.arg3
- && arg1.equals(comp.arg1);
- }
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnorableRunner.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnorableRunner.java
deleted file mode 100644
index 33e6d4862b..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnorableRunner.java
+++ /dev/null
@@ -1,139 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing.dynaignore;
-
-import org.junit.runner.Description;
-import org.junit.runner.Result;
-import org.junit.runner.Runner;
-import org.junit.runner.notification.Failure;
-import org.junit.runner.notification.RunListener;
-import org.junit.runner.notification.RunNotifier;
-import org.junit.runner.notification.StoppedByUserException;
-import org.junit.runners.BlockJUnit4ClassRunner;
-import org.junit.runners.model.InitializationError;
-
-/**
- * @version $Rev$ $Date$
- */
-public class IgnorableRunner extends Runner {
-
- private static final class Notifier extends RunNotifier {
- private final RunNotifier notifier;
-
- public Notifier(final RunNotifier notifier) {
- this.notifier = notifier;
- }
-
- public void addFirstListener(final RunListener listener) {
- notifier.addFirstListener(listener);
- }
-
- public void addListener(final RunListener listener) {
- notifier.addListener(listener);
- }
-
- @Override
- public boolean equals(final Object obj) {
- return notifier.equals(obj);
- }
-
- @Override
- public void fireTestFailure(final Failure failure) {
- if (failure.getException().getClass() == IgnoreTest.class) {
- notifier.fireTestIgnored(failure.getDescription());
- } else {
- notifier.fireTestFailure(failure);
- }
- }
-
- @Override
- public void fireTestFinished(final Description description) {
- notifier.fireTestFinished(description);
- }
-
- @Override
- public void fireTestIgnored(final Description description) {
- notifier.fireTestIgnored(description);
- }
-
- @Override
- public void fireTestRunFinished(final Result result) {
- notifier.fireTestRunFinished(result);
- }
-
- @Override
- public void fireTestRunStarted(final Description description) {
- notifier.fireTestRunStarted(description);
- }
-
- @Override
- public void fireTestStarted(final Description description)
- throws StoppedByUserException {
- notifier.fireTestStarted(description);
- }
-
- @Override
- public int hashCode() {
- return notifier.hashCode();
- }
-
- @Override
- public void pleaseStop() {
- notifier.pleaseStop();
- }
-
- @Override
- public void removeListener(final RunListener listener) {
- notifier.removeListener(listener);
- }
-
- public void testAborted(final Description description,
- final Throwable cause) {
- ((Notifier) notifier).testAborted(description, cause);
- }
-
- @Override
- public String toString() {
- return notifier.toString();
- }
-
- }
-
- Runner runner = null;
-
- public IgnorableRunner(Class<?> testClass) {
- try {
- runner = new BlockJUnit4ClassRunner(testClass);
- } catch (InitializationError e) {
- e.printStackTrace();
- }
- }
-
- @Override
- public Description getDescription() {
- return runner.getDescription();
- }
-
- @Override
- public void run(RunNotifier notifier) {
- runner.run(new Notifier(notifier));
- }
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnoreTest.java b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnoreTest.java
deleted file mode 100644
index 3d736da19d..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/dynaignore/IgnoreTest.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/*
- * 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.tuscany.sca.binding.erlang.testing.dynaignore;
-
-/**
- * @version $Rev$ $Date$
- */
-public final class IgnoreTest extends Error {
-
- private static final long serialVersionUID = 1L;
-
-}
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/resources/ErlangReference.composite b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/resources/ErlangReference.composite
deleted file mode 100644
index 63bce2b3fc..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/resources/ErlangReference.composite
+++ /dev/null
@@ -1,58 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- * 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.
--->
-<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
- xmlns:tuscany="http://tuscany.apache.org/xmlns/sca/1.0"
- targetNamespace="http://sample"
- xmlns:sample="http://sample"
- name="ErlangReferenceBinding">
-
- <component name="ReferenceTest">
- <implementation.java class="org.apache.tuscany.sca.binding.erlang.testing.ReferenceTestComponentImpl" />
- <reference name="mboxReference">
- <tuscany:binding.erlang node="MboxServer" mbox="true"/>
- </reference>
-
- <reference name="timeoutMboxReference">
- <tuscany:binding.erlang node="MboxServer" mbox="true" timeout="500"/>
- </reference>
-
- <reference name="cookieMboxReference">
- <tuscany:binding.erlang node="MboxServer" mbox="true" cookie="cookie"/>
- </reference>
-
- <reference name="moduleReference">
- <tuscany:binding.erlang node="RPCServer" module="hello"/>
- </reference>
-
- <reference name="cookieModuleReference">
- <tuscany:binding.erlang node="RPCServerCookie" module="hello_cookie" cookie="cookie"/>
- </reference>
-
- <reference name="invalidCookieModuleReference">
- <tuscany:binding.erlang node="RPCServerCookie" module="hello_cookie" cookie="invalid_cookie"/>
- </reference>
-
- <reference name="timeoutModuleReference">
- <tuscany:binding.erlang node="RPCServerTimeout" module="hello_timeout" timeout="500"/>
- </reference>
-
- </component>
-
-</composite> \ No newline at end of file
diff --git a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/resources/ErlangService.composite b/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/resources/ErlangService.composite
deleted file mode 100644
index d48a225481..0000000000
--- a/branches/sca-java-1.5.1/modules/binding-erlang-runtime/src/test/resources/ErlangService.composite
+++ /dev/null
@@ -1,54 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
- * 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.
--->
-<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
- xmlns:tuscany="http://tuscany.apache.org/xmlns/sca/1.0"
- targetNamespace="http://sample"
- xmlns:sample="http://sample"
- name="ErlangServiceBinding">
-
- <component name="ServiceTest">
- <implementation.java class="org.apache.tuscany.sca.binding.erlang.testing.ServiceTestComponentImpl" />
- </component>
- <service name="ServiceTest" promote="ServiceTest">
- <interface.java interface="org.apache.tuscany.sca.binding.erlang.testing.ServiceTestComponent" />
- <tuscany:binding.erlang node="RPCServer" module="hello"/>
- </service>
- <service name="ServiceTestMbox" promote="ServiceTest">
- <interface.java interface="org.apache.tuscany.sca.binding.erlang.testing.ServiceTestComponent" />
- <tuscany:binding.erlang node="RPCServerMbox" mbox="true"/>
- </service>
-
- <component name="ServiceTestTimeout">
- <implementation.java class="org.apache.tuscany.sca.binding.erlang.testing.ServiceTestComponentImplTimeout" />
- </component>
- <service name="ServiceTestTimeout" promote="ServiceTestTimeout">
- <interface.java interface="org.apache.tuscany.sca.binding.erlang.testing.ServiceTestComponent" />
- <tuscany:binding.erlang node="RPCServerTimeout" module="hello_timeout" timeout="500"/>
- </service>
-
- <component name="ServiceTestCookie">
- <implementation.java class="org.apache.tuscany.sca.binding.erlang.testing.ServiceTestComponentImpl" />
- </component>
- <service name="ServiceTestCookie" promote="ServiceTestCookie">
- <interface.java interface="org.apache.tuscany.sca.binding.erlang.testing.ServiceTestComponent" />
- <tuscany:binding.erlang node="RPCServerCookie" module="hello_cookie" cookie="cookie"/>
- </service>
-
-</composite> \ No newline at end of file