From a521a2d74c480c53c1004e7e5e2addd28a0578f4 Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Sat, 12 Apr 2014 20:37:55 +0200
Subject: wip

---
 .../java/org/jenkinsci/plugins/calamus/MqClient.java  | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)

(limited to 'calamus-jenkins-plugin')

diff --git a/calamus-jenkins-plugin/src/main/java/org/jenkinsci/plugins/calamus/MqClient.java b/calamus-jenkins-plugin/src/main/java/org/jenkinsci/plugins/calamus/MqClient.java
index 6ca4264..01e4176 100644
--- a/calamus-jenkins-plugin/src/main/java/org/jenkinsci/plugins/calamus/MqClient.java
+++ b/calamus-jenkins-plugin/src/main/java/org/jenkinsci/plugins/calamus/MqClient.java
@@ -6,10 +6,13 @@ import javax.jms.Connection;
 import javax.jms.DeliveryMode;
 import javax.jms.Destination;
 import javax.jms.JMSException;
-import javax.jms.MapMessage;
 import javax.jms.MessageProducer;
 import javax.jms.Session;
+import java.io.CharArrayWriter;
+import java.io.IOException;
+import java.util.Properties;
 
+import static java.lang.String.valueOf;
 import static javax.jms.Session.AUTO_ACKNOWLEDGE;
 
 public class MqClient {
@@ -32,16 +35,18 @@ public class MqClient {
             MessageProducer producer = session.createProducer(destination);
             producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
 
-            MapMessage message = session.createMapMessage();
-            message.setString("jobName", jobName);
-            message.setInt("buildNumber", buildNumber);
-            message.setString("result", result);
+            Properties properties = new Properties();
+            properties.setProperty("jobName", jobName);
+            properties.setProperty("buildNumber", valueOf(buildNumber));
+            properties.setProperty("result", result);
 
-            producer.send(message);
+            CharArrayWriter buf = new CharArrayWriter();
+            properties.store(buf, null);
+            producer.send(session.createTextMessage(buf.toString()));
 
             session.close();
             connection.close();
-        } catch (JMSException e) {
+        } catch (JMSException | IOException e) {
             e.printStackTrace();
         }
     }
-- 
cgit v1.2.3