Copy travelsample-1.0-RC3 tag as travelsample-1.0

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

3 files changed, 184 insertions, 0 deletions

diff --git a/sca-java-1.x/tags/travelsample-1.0/contributions/travelcatalog/src/main/java/com/tuscanyscatours/travelcatalog/TravelCatalogSearch.java b/sca-java-1.x/tags/travelsample-1.0/contributions/travelcatalog/src/main/java/com/tuscanyscatours/travelcatalog/TravelCatalogSearch.java
new file mode 100644
index 0000000000..e558439f82
--- /dev/null
+++ b/sca-java-1.x/tags/travelsample-1.0/contributions/travelcatalog/src/main/java/com/tuscanyscatours/travelcatalog/TravelCatalogSearch.java
@@ -0,0 +1,32 @@
+/*

+ * 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 com.tuscanyscatours.travelcatalog;

+

+import org.osoa.sca.annotations.Remotable;

+

+import com.tuscanyscatours.common.TripItem;

+import com.tuscanyscatours.common.TripLeg;

+

+/**

+ * The TravelCatalogSearch service interface

+ */

+@Remotable

+public interface TravelCatalogSearch {

+    TripItem[] search(TripLeg tripLeg);

+}

diff --git a/sca-java-1.x/tags/travelsample-1.0/contributions/travelcatalog/src/main/java/com/tuscanyscatours/travelcatalog/impl/TravelCatalogImpl.java b/sca-java-1.x/tags/travelsample-1.0/contributions/travelcatalog/src/main/java/com/tuscanyscatours/travelcatalog/impl/TravelCatalogImpl.java
new file mode 100644
index 0000000000..90351720bb
--- /dev/null
+++ b/sca-java-1.x/tags/travelsample-1.0/contributions/travelcatalog/src/main/java/com/tuscanyscatours/travelcatalog/impl/TravelCatalogImpl.java
@@ -0,0 +1,127 @@
+/*

+ * 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 com.tuscanyscatours.travelcatalog.impl;

+

+import java.util.ArrayList;

+import java.util.List;

+import java.util.UUID;

+import java.util.concurrent.CountDownLatch;

+

+import org.osoa.sca.ComponentContext;

+import org.osoa.sca.RequestContext;

+import org.osoa.sca.ServiceReference;

+import org.osoa.sca.annotations.Context;

+import org.osoa.sca.annotations.Property;

+import org.osoa.sca.annotations.Reference;

+import org.osoa.sca.annotations.Scope;

+import org.osoa.sca.annotations.Service;

+

+import com.tuscanyscatours.common.Search;

+import com.tuscanyscatours.common.SearchCallback;

+import com.tuscanyscatours.common.TripItem;

+import com.tuscanyscatours.common.TripLeg;

+import com.tuscanyscatours.currencyconverter.CurrencyConverter;

+import com.tuscanyscatours.travelcatalog.TravelCatalogSearch;

+

+/**

+ * An implementation of the travel catalog service

+ */

+@Scope("COMPOSITE")

+@Service(interfaces = {TravelCatalogSearch.class})

+public class TravelCatalogImpl implements TravelCatalogSearch, SearchCallback {

+

+    @Reference

+    protected Search hotelSearch;

+

+    @Reference

+    protected Search flightSearch;

+

+    @Reference

+    protected Search carSearch;

+

+    @Reference

+    protected Search tripSearch;

+

+    @Property

+    public String quoteCurrencyCode = "USD";

+

+    @Reference

+    protected CurrencyConverter currencyConverter;

+

+    @Context

+    protected ComponentContext componentContext;

+

+    private List<TripItem> searchResults = new ArrayList<TripItem>();

+

+    CountDownLatch resultsReceivedCountdown;

+

+    // TravelSearch methods

+

+    public TripItem[] search(TripLeg tripLeg) {

+

+        resultsReceivedCountdown = new CountDownLatch(4);

+        searchResults.clear();

+

+        ServiceReference<Search> dynamicHotelSearch = componentContext.getServiceReference(Search.class, "hotelSearch");

+

+        dynamicHotelSearch.setCallbackID("HotelSearchCallbackID-" + tripLeg.getId());

+        dynamicHotelSearch.getService().searchAsynch(tripLeg);

+

+        flightSearch.searchAsynch(tripLeg);

+        carSearch.searchAsynch(tripLeg);

+        tripSearch.searchAsynch(tripLeg);

+

+        System.out.println("going into wait");

+

+        try {

+            resultsReceivedCountdown.await();

+        } catch (InterruptedException ex) {

+        }

+

+        for (TripItem tripItem : searchResults) {

+            tripItem.setId(UUID.randomUUID().toString());

+            tripItem.setTripId(tripLeg.getId());

+            tripItem

+                .setPrice(currencyConverter.convert(tripItem.getCurrency(), quoteCurrencyCode, tripItem.getPrice()));

+            tripItem.setCurrency(quoteCurrencyCode);

+        }

+

+        return searchResults.toArray(new TripItem[searchResults.size()]);

+    }

+

+    // SearchCallback methods

+

+    public synchronized void searchResults(TripItem[] items) {

+        RequestContext requestContext = componentContext.getRequestContext();

+        Object callbackID = requestContext.getServiceReference().getCallbackID();

+        System.out.println("Asynch response - " + callbackID);

+

+        if (items != null) {

+            for (int i = 0; i < items.length; i++) {

+                searchResults.add(items[i]);

+            }

+        }

+

+        resultsReceivedCountdown.countDown();

+    }

+

+    public void setPercentComplete(String searchComponent, int percentComplete) {

+        // Not used at the moment

+    }

+}

diff --git a/sca-java-1.x/tags/travelsample-1.0/contributions/travelcatalog/src/main/resources/META-INF/sca-contribution.xml b/sca-java-1.x/tags/travelsample-1.0/contributions/travelcatalog/src/main/resources/META-INF/sca-contribution.xml
new file mode 100644
index 0000000000..b18ae45a09
--- /dev/null
+++ b/sca-java-1.x/tags/travelsample-1.0/contributions/travelcatalog/src/main/resources/META-INF/sca-contribution.xml
@@ -0,0 +1,25 @@
+<?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.    

+-->

+<contribution xmlns="http://www.osoa.org/xmlns/sca/1.0">

+    <import.java package="com.tuscanyscatours.common" />

+    <import.java package="com.tuscanyscatours.currencyconverter" />

+    <export.java package="com.tuscanyscatours.travelcatalog" />

+    <export.java package="com.tuscanyscatours.travelcatalog.impl" />

+</contribution>