1 files changed, 17 insertions, 2 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
index 410ff10cfe..4919d2a629 100644
--- 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
@@ -83,9 +83,23 @@ public class TravelCatalogImpl implements TravelCatalogSearch, SearchCallback{
         dynamicHotelSearch.getService().searchAsynch(tripLeg);
         
         flightSearch.searchAsynch(tripLeg);
+        
+        while (responsesReceived < 2){
+            try {
+                synchronized (this) {
+                    this.wait();
+                }
+            } catch (InterruptedException ex){
+                // do nothing
+            	System.out.println("waiting for response");
+            }
+        }  
+        
         carSearch.searchAsynch(tripLeg);
         tripSearch.searchAsynch(tripLeg);
         
+        System.out.println("going into wait");
+        
         while (responsesReceived < 4){
             try {
                 synchronized (this) {
@@ -93,8 +107,9 @@ public class TravelCatalogImpl implements TravelCatalogSearch, SearchCallback{
                 }
             } catch (InterruptedException ex){
                 // do nothing
+            	System.out.println("waiting for response");
             }
-        }
+        }     
         
         for (TripItem tripItem : searchResults){
             tripItem.setId(UUID.randomUUID().toString());
@@ -113,7 +128,7 @@ public class TravelCatalogImpl implements TravelCatalogSearch, SearchCallback{
     public void searchResults(TripItem[] items){
         RequestContext requestContext = componentContext.getRequestContext();
         Object callbackID = requestContext.getServiceReference().getCallbackID();
-        System.out.println(callbackID);
+        System.out.println("Asynch response - " + callbackID);
         
         if (items != null) {
             for(int i = 0; i < items.length; i++ ){