1 files changed, 22 insertions, 13 deletions

diff --git a/calamus-nexus-plugin/src/main/java/io/trygvis/calamus/nexus/MqClient.java b/calamus-nexus-plugin/src/main/java/io/trygvis/calamus/nexus/MqClient.java
index 51b2b3a..2564ed9 100644
--- a/calamus-nexus-plugin/src/main/java/io/trygvis/calamus/nexus/MqClient.java
+++ b/calamus-nexus-plugin/src/main/java/io/trygvis/calamus/nexus/MqClient.java
@@ -1,26 +1,33 @@
 package io.trygvis.calamus.nexus;
 
 import org.apache.activemq.ActiveMQConnectionFactory;
+import org.slf4j.Logger;
 
 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 javax.jms.Session.AUTO_ACKNOWLEDGE;
+import static org.apache.commons.lang.StringUtils.trimToEmpty;
+import static org.slf4j.LoggerFactory.getLogger;
 
 public class MqClient {
 
-    ActiveMQConnectionFactory connectionFactory;
+    private final Logger log = getLogger(getClass());
+
+    private final ActiveMQConnectionFactory connectionFactory;
 
     public MqClient(String brokerUrl) {
         this.connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
     }
 
-    public void sendMessage(String repository, String groupId, String artifactId, String version, String type, String classifier) {
+    public void sendMessage(String repository, String groupId, String artifactId, String version, String classifier, String extension) {
         try {
             Connection connection = connectionFactory.createConnection();
             connection.start();
@@ -32,20 +39,22 @@ public class MqClient {
             MessageProducer producer = session.createProducer(destination);
             producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
 
-            MapMessage message = session.createMapMessage();
-            message.setString("repository", repository);
-            message.setString("groupId", groupId);
-            message.setString("artifactId", artifactId);
-            message.setString("version", version);
-            message.setString("type", type);
-            message.setString("classifier", classifier);
+            Properties p = new Properties();
+            p.setProperty("repository", repository);
+            p.setProperty("groupId", groupId);
+            p.setProperty("artifactId", artifactId);
+            p.setProperty("version", version);
+            p.setProperty("classifier", trimToEmpty(classifier));
+            p.setProperty("extension", extension);
 
-            producer.send(message);
+            CharArrayWriter buf = new CharArrayWriter();
+            p.store(buf, null);
+            producer.send(session.createTextMessage(buf.toString()));
 
             session.close();
             connection.close();
-        } catch (JMSException e) {
-            e.printStackTrace();
+        } catch (JMSException | IOException e) {
+            log.warn("Unable to send message to broker", e);
         }
     }
 }