Merge pull request #259 from pymma/kafka

Add TransactionID in the swimming pool example

drools-framework-base-tools-parent/drools-framework-examples/drools-framework-swimmingpool-web-ui/src/main/java/org/chtijbug/swimmingpool/web/controller/QuoteController.java

@@ -83,6 +83,12 @@ public class QuoteController {
         return clientHttpRequest -> {
             ObjectMapper mapper = new ObjectMapper();
             mapper.writeValue(clientHttpRequest.getBody(), updatedInstance);
+            if (updatedInstance.getSessionLogging()!= null &&
+                updatedInstance.getSessionLogging().length()>0){
+                clientHttpRequest.getHeaders().add(
+                        "transactionId",  updatedInstance.getSessionLogging());
+
+            }
             clientHttpRequest.getHeaders().add(
                     HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
             clientHttpRequest.getHeaders().add(

drools-framework-base-tools-parent/drools-framework-examples/drools-framework-swimmingpool-web-ui/src/main/resources/static/index.html

@@ -177,6 +177,11 @@
                                         <td>Subscription price :</td>
                                         <td>{{quoteResult.subscription.price}}</td>
                                     </tr>
+                                    <tr>
+                                        <td>TransactionID :</td>
+                                        <td>{{quoteResult.sessionLogging}}</td>
+
+                                    </tr>
 
                                 </table>
                             </div>

drools-framework-base-tools-parent/drools-framework-examples/drools-framework-swimmingpool-web-ui/src/main/resources/static/js/app.js

@@ -107,6 +107,7 @@ productManagerModule.controller('quoteManagerController', function ($scope, $htt
 
     $scope.calculatePrice = function () {
         var myQuote = $scope.quote;
+        myQuote.sessionLogging=uuidv4();
         $http.put(urlBase + "/quote/calculate/" + $scope.containerid + "/", myQuote).success(function (data) {
             $scope.quoteResult = data;
             $scope.allSessionExecutionDetails = JSON.parse(data.sessionLogging);
@@ -114,7 +115,12 @@ productManagerModule.controller('quoteManagerController', function ($scope, $htt
             // $scope.sessionLogging=data.sessionLogging;
         })
     }
-
+    function uuidv4() {
+        return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function(c) {
+            var r = Math.random() * 16 | 0, v = c == 'x' ? r : (r & 0x3 | 0x8);
+            return v.toString(16);
+        });
+    }
 
 });