summaryrefslogtreecommitdiffstats
path: root/sandbox/travelsample/travelcatalog-contribution/src
diff options
context:
space:
mode:
Diffstat (limited to 'sandbox/travelsample/travelcatalog-contribution/src')
-rw-r--r--sandbox/travelsample/travelcatalog-contribution/src/scatours/travelcatalog/TravelCatalogImpl.java12
1 files changed, 9 insertions, 3 deletions
diff --git a/sandbox/travelsample/travelcatalog-contribution/src/scatours/travelcatalog/TravelCatalogImpl.java b/sandbox/travelsample/travelcatalog-contribution/src/scatours/travelcatalog/TravelCatalogImpl.java
index 524507589d..2369baaff1 100644
--- a/sandbox/travelsample/travelcatalog-contribution/src/scatours/travelcatalog/TravelCatalogImpl.java
+++ b/sandbox/travelsample/travelcatalog-contribution/src/scatours/travelcatalog/TravelCatalogImpl.java
@@ -57,6 +57,9 @@ public class TravelCatalogImpl implements TravelCatalogSearch, SearchCallback{
@Reference
protected Search carSearch;
+
+ @Reference
+ protected Search tripSearch;
@Property
public String quoteCurrencyCode = "USD";
@@ -86,8 +89,9 @@ public class TravelCatalogImpl implements TravelCatalogSearch, SearchCallback{
flightSearch.searchAsynch(tripLeg);
carSearch.searchAsynch(tripLeg);
+ tripSearch.searchAsynch(tripLeg);
- while (responsesReceived < 3){
+ while (responsesReceived < 4){
try {
synchronized (this) {
this.wait();
@@ -116,8 +120,10 @@ public class TravelCatalogImpl implements TravelCatalogSearch, SearchCallback{
Object callbackID = requestContext.getServiceReference().getCallbackID();
System.out.println(callbackID);
- for(int i = 0; i < items.length; i++ ){
- searchResults.add(items[i]);
+ if (items != null) {
+ for(int i = 0; i < items.length; i++ ){
+ searchResults.add(items[i]);
+ }
}
responsesReceived++;