camel message sends now work with headers

hawtio · Apr 24, 2013 · af53fd3 · af53fd3
1 parent f26f9a2
commit af53fd3
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/hawtio-web/src/main/webapp/app/camel/js/send.ts b/hawtio-web/src/main/webapp/app/camel/js/send.ts
@@ -70,18 +70,22 @@ module Camel {
 
             var jolokia = workspace.jolokia;
             // if camel then use a different operation on the camel context mbean
+            var callback = onSuccess(sendWorked);
             if (selection.domain === "org.apache.camel") {
               var uri = selection.title;
               mbean = getSelectionCamelContextMBean(workspace);
               if (mbean) {
-                jolokia.execute(mbean, "sendStringBody(java.lang.String,java.lang.String)", uri, body, onSuccess(sendWorked));
+                if (headers) {
+                  jolokia.execute(mbean, "sendBodyAndHeaders(java.lang.String, java.lang.Object, java.util.Map)", uri, body, headers, callback);
+                } else {
+                  jolokia.execute(mbean, "sendStringBody(java.lang.String, java.lang.String)", uri, body, callback);
+                }
               } else {
                 notification("error", "Could not find CamelContext MBean!");
               }
             } else {
               var user = localStorage["activemqUserName"];
               var pwd = localStorage["activemqPassword"];
-              var callback = onSuccess(sendWorked);
               if (headers) {
                 jolokia.execute(mbean, "sendTextMessage(java.util.Map, java.lang.String, java.lang.String, java.lang.String)", headers, body, user, pwd, callback);
               } else {