Travel sample restructure

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

3 files changed, 188 insertions, 0 deletions

diff --git a/sandbox/travelsample/contributions/travelcatalog-contribution/src/main/java/scatours/travelcatalog/TravelCatalogImpl.java b/sandbox/travelsample/contributions/travelcatalog-contribution/src/main/java/scatours/travelcatalog/TravelCatalogImpl.java
new file mode 100644
index 0000000000..410ff10cfe
--- /dev/null
+++ b/sandbox/travelsample/contributions/travelcatalog-contribution/src/main/java/scatours/travelcatalog/TravelCatalogImpl.java
@@ -0,0 +1,132 @@
+/*

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

+

+import java.util.ArrayList;

+import java.util.List;

+import java.util.UUID;

+

+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 scatours.common.Search;

+import scatours.common.SearchCallback;

+import scatours.common.TripItem;

+import scatours.common.TripLeg;

+import scatours.currencyconverter.CurrencyConverter;

+

+/**

+ * An implementation of the Trip 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 int responsesReceived = 0;

+    

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

+    

+    // TravelSearch methods

+    

+    public TripItem[] search(TripLeg tripLeg) {

+        

+        searchResults.clear();

+        responsesReceived = 0;

+        

+        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);

+        

+        while (responsesReceived < 4){

+            try {

+                synchronized (this) {

+                    this.wait();

+                }

+            } catch (InterruptedException ex){

+                // do nothing

+            }

+        }

+        

+        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 void searchResults(TripItem[] items){

+        RequestContext requestContext = componentContext.getRequestContext();

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

+        System.out.println(callbackID);

+        

+        if (items != null) {

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

+                searchResults.add(items[i]);

+            }

+        }

+        

+        responsesReceived++;

+        try {

+            synchronized (this) {

+                this.notifyAll();

+            }

+        } catch (Exception ex) {

+        }

+    }    

+}

diff --git a/sandbox/travelsample/contributions/travelcatalog-contribution/src/main/java/scatours/travelcatalog/TravelCatalogSearch.java b/sandbox/travelsample/contributions/travelcatalog-contribution/src/main/java/scatours/travelcatalog/TravelCatalogSearch.java
new file mode 100644
index 0000000000..480fb96f7e
--- /dev/null
+++ b/sandbox/travelsample/contributions/travelcatalog-contribution/src/main/java/scatours/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 scatours.travelcatalog;

+

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

+

+import scatours.common.TripItem;

+import scatours.common.TripLeg;

+

+/**

+ * The Trip service interface

+ */

+@Remotable

+public interface TravelCatalogSearch {

+    TripItem[] search(TripLeg tripLeg);

+}

diff --git a/sandbox/travelsample/contributions/travelcatalog-contribution/src/main/resources/META-INF/sca-contribution.xml b/sandbox/travelsample/contributions/travelcatalog-contribution/src/main/resources/META-INF/sca-contribution.xml
new file mode 100644
index 0000000000..7b3f7b6a0e
--- /dev/null
+++ b/sandbox/travelsample/contributions/travelcatalog-contribution/src/main/resources/META-INF/sca-contribution.xml
@@ -0,0 +1,24 @@
+<?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="scatours.common"/>

+   <import.java package="scatours.currencyconverter"/>

+   <export.java package="scatours.travelcatalog"/>

+</contribution>
\ No newline at end of file