summaryrefslogtreecommitdiffstats
path: root/sca-java-1.x/branches/sca-java-1.6/itest/references-collection
diff options
context:
space:
mode:
authorantelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>2009-12-21 11:58:17 +0000
committerantelder <antelder@13f79535-47bb-0310-9956-ffa450edef68>2009-12-21 11:58:17 +0000
commit23d5587f8a4a4dfa5fb2f5d9497d04733cdfe8df (patch)
tree2bfca23b82c9c9a3909cfe7019c1ffdedaa1e63b /sca-java-1.x/branches/sca-java-1.6/itest/references-collection
parent1d9d90639d2b679dc82443dd1b2011effc34261b (diff)
Copy 1.x trunk to branches for start of 1.6 release
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@892786 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'sca-java-1.x/branches/sca-java-1.6/itest/references-collection')
-rw-r--r--sca-java-1.x/branches/sca-java-1.6/itest/references-collection/pom.xml53
-rw-r--r--sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/Crawler.java46
-rw-r--r--sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/CrawlerController.java41
-rw-r--r--sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/CrawlerControllerImpl.java80
-rw-r--r--sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/CrawlerImpl.java69
-rw-r--r--sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/SpecialCrawlerImpl.java69
-rw-r--r--sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/resources/test.composite51
-rw-r--r--sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/test/java/crawler/ReferenceMultiplicityTestCase.java134
8 files changed, 543 insertions, 0 deletions
diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/pom.xml b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/pom.xml
new file mode 100644
index 0000000000..31ca4e6907
--- /dev/null
+++ b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/pom.xml
@@ -0,0 +1,53 @@
+<?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.
+-->
+<project>
+ <modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-itest</artifactId>
+ <version>1.6-SNAPSHOT</version>
+ <relativePath>../pom.xml</relativePath>
+ </parent>
+ <artifactId>itest-references-collection</artifactId>
+ <name>Apache Tuscany SCA iTest References Collection</name>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-host-embedded</artifactId>
+ <version>1.6-SNAPSHOT</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-implementation-java-runtime</artifactId>
+ <version>1.6-SNAPSHOT</version>
+ <scope>runtime</scope>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.tuscany.sca</groupId>
+ <artifactId>tuscany-binding-ws-axis2</artifactId>
+ <version>1.6-SNAPSHOT</version>
+ <scope>runtime</scope>
+ </dependency>
+
+ </dependencies>
+</project>
diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/Crawler.java b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/Crawler.java
new file mode 100644
index 0000000000..2607e9aabc
--- /dev/null
+++ b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/Crawler.java
@@ -0,0 +1,46 @@
+/*
+ * 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 crawler;
+
+import org.osoa.sca.annotations.Conversational;
+import org.osoa.sca.annotations.EndsConversation;
+import org.osoa.sca.annotations.Remotable;
+
+@Remotable
+@Conversational
+public interface Crawler
+{
+ /**
+ * Returns the crawler Id.
+ * @return a String containing the CrawlerId
+ */
+ String getCrawlerId();
+
+ /**
+ * Starts a crawl process.
+ * @return a message that the crawl was started
+ */
+ String crawl();
+
+ /**
+ * Closes the conversation.
+ */
+ @EndsConversation
+ String close();
+}
diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/CrawlerController.java b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/CrawlerController.java
new file mode 100644
index 0000000000..11b1b6b580
--- /dev/null
+++ b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/CrawlerController.java
@@ -0,0 +1,41 @@
+/*
+ * 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 crawler;
+
+import org.osoa.sca.annotations.Remotable;
+
+@Remotable
+public interface CrawlerController
+{
+ /**
+ * Tries to return a Crawler with the given Id in the list of crawlers.
+ * It uses the getServiceReference() method which should throw an exception because of multiplicity 0..n
+ * @param crawlerId the id of the Crawler
+ * @return the Crawler
+ */
+ Crawler getCrawler(String crawlerId);
+
+ /**
+ * Tries to return a Crawler with the given Id in the list of crawlers.
+ * It uses the getServiceReferences() method which shoulkd work properly with multiplicity 0..n
+ * @param crawlerId the id of the Crawler
+ * @return the Crawler
+ */
+ Crawler findCrawler(String crawlerId);
+}
diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/CrawlerControllerImpl.java b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/CrawlerControllerImpl.java
new file mode 100644
index 0000000000..1ca2a3797a
--- /dev/null
+++ b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/CrawlerControllerImpl.java
@@ -0,0 +1,80 @@
+/*
+ * 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 crawler.impl;
+
+import crawler.Crawler;
+import crawler.CrawlerController;
+
+import java.util.Collection;
+import java.util.List;
+
+import org.apache.tuscany.sca.api.ComponentContextExtension;
+import org.osoa.sca.ComponentContext;
+import org.osoa.sca.annotations.AllowsPassByReference;
+import org.osoa.sca.annotations.Context;
+import org.osoa.sca.annotations.Reference;
+import org.osoa.sca.annotations.Scope;
+import org.osoa.sca.annotations.Service;
+
+@Service(CrawlerController.class)
+@Scope("COMPOSITE")
+@AllowsPassByReference
+public class CrawlerControllerImpl implements CrawlerController
+{
+ @Context
+ protected ComponentContext componentContext;
+
+ @Reference
+ public List<Crawler> crawlers;
+
+ /**
+ * @see CrawlerController#getCrawler(String)
+ */
+ public Crawler getCrawler(String crawlerId)
+ {
+ for (int i = 0; i < crawlers.size(); i++)
+ {
+ Crawler crawler = crawlers.get(i);
+ String id = crawler.getCrawlerId();
+ if (crawlerId.equals(id))
+ {
+ Crawler newCrawler = componentContext.getService(Crawler.class, "crawlers");
+ return newCrawler;
+ }
+ }
+ throw new RuntimeException("No crawler with id " + crawlerId + " found");
+ }
+
+ /**
+ * @see CrawlerController#findCrawler(String)
+ */
+ public Crawler findCrawler(String crawlerId)
+ {
+ Collection<Crawler> crawlers = ((ComponentContextExtension)componentContext).getServices(Crawler.class, "crawlers");
+ for (Crawler crawler : crawlers)
+ {
+ String id = crawler.getCrawlerId();
+ if (crawlerId.equals(id))
+ {
+ return crawler;
+ }
+ }
+ throw new RuntimeException("No crawler with id " + crawlerId + " found");
+ }
+}
diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/CrawlerImpl.java b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/CrawlerImpl.java
new file mode 100644
index 0000000000..0224d7750e
--- /dev/null
+++ b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/CrawlerImpl.java
@@ -0,0 +1,69 @@
+/*
+ * 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 crawler.impl;
+
+import crawler.Crawler;
+
+import org.osoa.sca.ComponentContext;
+import org.osoa.sca.annotations.AllowsPassByReference;
+import org.osoa.sca.annotations.Context;
+import org.osoa.sca.annotations.ConversationID;
+import org.osoa.sca.annotations.Property;
+import org.osoa.sca.annotations.Scope;
+import org.osoa.sca.annotations.Service;
+
+@Service(Crawler.class)
+@AllowsPassByReference
+@Scope("CONVERSATION")
+public class CrawlerImpl implements Crawler
+{
+ @ConversationID
+ protected String conversationId;
+
+ @Property
+ protected String crawlerId;
+
+ @Context
+ protected ComponentContext componentContext;
+
+ /**
+ * @see Crawler#getCrawlerId()
+ */
+ public String getCrawlerId()
+ {
+ return crawlerId;
+ }
+
+ /**
+ * @see Crawler#crawl()
+ */
+ public String crawl()
+ {
+ System.out.println("started crawl with conversation " + conversationId);
+ return "started crawl with id " + getCrawlerId();
+ }
+
+ /**
+ * @see Crawler#close()
+ */
+ public String close()
+ {
+ return "ended conversation with id " + getCrawlerId();
+ }
+} \ No newline at end of file
diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/SpecialCrawlerImpl.java b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/SpecialCrawlerImpl.java
new file mode 100644
index 0000000000..e486a23e23
--- /dev/null
+++ b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/java/crawler/impl/SpecialCrawlerImpl.java
@@ -0,0 +1,69 @@
+/*
+ * 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 crawler.impl;
+
+import crawler.Crawler;
+
+import org.osoa.sca.ComponentContext;
+import org.osoa.sca.annotations.AllowsPassByReference;
+import org.osoa.sca.annotations.Context;
+import org.osoa.sca.annotations.ConversationID;
+import org.osoa.sca.annotations.Property;
+import org.osoa.sca.annotations.Scope;
+import org.osoa.sca.annotations.Service;
+
+@Service(Crawler.class)
+@AllowsPassByReference
+@Scope("CONVERSATION")
+public class SpecialCrawlerImpl implements Crawler
+{
+ @ConversationID
+ protected String conversationId;
+
+ @Property
+ protected String crawlerId;
+
+ @Context
+ protected ComponentContext componentContext;
+
+ /**
+ * @see Crawler#getCrawlerId()
+ */
+ public String getCrawlerId()
+ {
+ return crawlerId;
+ }
+
+ /**
+ * @see Crawler#crawl()
+ */
+ public String crawl()
+ {
+ System.out.println("started crawl with conversation " + conversationId);
+ return "started crawl with id " + getCrawlerId();
+ }
+
+ /**
+ * @see Crawler#close()
+ */
+ public String close()
+ {
+ return "ended conversation with id " + getCrawlerId();
+ }
+} \ No newline at end of file
diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/resources/test.composite b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/resources/test.composite
new file mode 100644
index 0000000000..ed3adfc7ae
--- /dev/null
+++ b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/main/resources/test.composite
@@ -0,0 +1,51 @@
+<?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:t="http://tuscany.apache.org/xmlns/sca/1.0"
+ targetNamespace="http://crawler"
+ xmlns:crawler="http://crawler"
+ name="crawler">
+
+ <component name="CrawlerControllerComponent">
+ <implementation.java class="crawler.impl.CrawlerControllerImpl"/>
+ <service name="CrawlerController">
+ <interface.java interface="crawler.CrawlerController" />
+ </service>
+ <reference name="crawlers" multiplicity="1..n" target="CrawlerComponent SpecialCrawlerComponent" />
+ </component>
+
+ <component name="CrawlerComponent">
+ <implementation.java class="crawler.impl.CrawlerImpl"/>
+ <property name="crawlerId">normalcrawler</property>
+ <service name="Crawler">
+ <interface.java interface="crawler.Crawler" />
+ </service>
+ </component>
+
+ <component name="SpecialCrawlerComponent">
+ <implementation.java class="crawler.impl.SpecialCrawlerImpl"/>
+ <property name="crawlerId">specialcrawler</property>
+ <service name="Crawler">
+ <interface.java interface="crawler.Crawler" />
+ </service>
+ </component>
+
+</composite> \ No newline at end of file
diff --git a/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/test/java/crawler/ReferenceMultiplicityTestCase.java b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/test/java/crawler/ReferenceMultiplicityTestCase.java
new file mode 100644
index 0000000000..1fc0e758c4
--- /dev/null
+++ b/sca-java-1.x/branches/sca-java-1.6/itest/references-collection/src/test/java/crawler/ReferenceMultiplicityTestCase.java
@@ -0,0 +1,134 @@
+/*
+ * 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 crawler;
+
+import crawler.Crawler;
+import crawler.CrawlerController;
+
+import org.apache.tuscany.sca.host.embedded.SCADomain;
+import org.apache.tuscany.sca.node.SCAClient;
+import org.apache.tuscany.sca.node.SCAContribution;
+import org.apache.tuscany.sca.node.SCANode;
+import org.apache.tuscany.sca.node.SCANodeFactory;
+import org.osoa.sca.ServiceRuntimeException;
+
+import junit.framework.TestCase;
+
+public class ReferenceMultiplicityTestCase extends TestCase
+{
+ private final String CRAWLER_ID = "normalcrawler";
+ private final String SPECIAL_CRAWLER_ID = "specialcrawler";
+
+ private static SCANode _scaDomain;
+ private CrawlerController _controller;
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see junit.framework.TestCase#setUp()
+ */
+ protected void setUp() throws Exception
+ {
+ SCANodeFactory nodeFactory = SCANodeFactory.newInstance();
+ _scaDomain = nodeFactory.createSCANode("test.composite",
+ new SCAContribution("crawler", "./target/classes"));
+ assertNotNull(_scaDomain);
+ _scaDomain.start();
+ _controller = ((SCAClient)_scaDomain).getService(CrawlerController.class, "CrawlerControllerComponent");
+ assertNotNull(_controller);
+ }
+
+ /**
+ * {@inheritDoc}
+ *
+ * @see junit.framework.TestCase#tearDown()
+ */
+ protected void tearDown() throws Exception
+ {
+ _controller = null;
+ if (_scaDomain != null)
+ {
+ _scaDomain.stop();
+ _scaDomain = null;
+ }
+ }
+
+ public void testGetCrawler() throws Exception
+ {
+ try
+ {
+ _controller.getCrawler(CRAWLER_ID);
+ fail("Expected exception");
+ }
+ catch (ServiceRuntimeException e)
+ {
+ assertEquals("Unexpected error message", "Reference crawlers has multiplicity ONE_N", e.getMessage());
+ }
+ catch (Exception e)
+ {
+ fail("Expected ServiceRuntimeException, not a " + e.getClass());
+ }
+
+ try
+ {
+ _controller.getCrawler(SPECIAL_CRAWLER_ID);
+ fail("Expected exception");
+ }
+ catch (ServiceRuntimeException e)
+ {
+ assertEquals("Unexpected error message", "Reference crawlers has multiplicity ONE_N", e.getMessage());
+ }
+ catch (Exception e)
+ {
+ fail("Expected ServiceRuntimeException, not a " + e.getClass());
+ }
+ }
+/*
+ public void testFindCrawler() throws Exception
+ {
+ try
+ {
+ Crawler crawler = _controller.findCrawler(CRAWLER_ID);
+ assertNotNull(crawler);
+ String msg = crawler.crawl();
+ assertEquals("Received unexpected msg", "started crawl with id " + CRAWLER_ID, msg);
+ msg = crawler.close();
+ assertEquals("Received unexpected msg", "ended conversation with id " + CRAWLER_ID, msg);
+ }
+ catch (Exception e)
+ {
+ fail("Unexpected Exception " + e.getClass());
+ }
+
+ try
+ {
+ Crawler crawler = _controller.findCrawler(SPECIAL_CRAWLER_ID);
+ assertNotNull(crawler);
+ String msg = crawler.crawl();
+ assertEquals("Received unexpected msg", "started crawl with id " + SPECIAL_CRAWLER_ID, msg);
+ msg = crawler.close();
+ assertEquals("Received unexpected msg", "ended conversation with id " + SPECIAL_CRAWLER_ID, msg);
+ }
+ catch (Exception e)
+ {
+ fail("Unexpected Exception " + e.getClass());
+ }
+ }
+*/
+}