Wrap the data in another object, as Alerts expects it that way.

hawkular · Feb 24, 2015 · 8850498 · 8850498
1 parent 614fd9a
commit 8850498
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/modules/pinger/src/main/java/org/hawkular/component/pinger/Log.java b/modules/pinger/src/main/java/org/hawkular/component/pinger/Log.java
@@ -40,7 +40,7 @@ public interface Log {
     @Message(id = 5001, value = "Pinging the remote threw an exception: %s")
     void wPingExeption(String message);
 
-    @LogMessage
+    @LogMessage(level = Logger.Level.DEBUG)
     @Message(id = 5002, value = "post status : %s")
     void metricPostStatus(String s);
 

diff --git a/modules/pinger/src/main/java/org/hawkular/component/pinger/MetricPublisher.java b/modules/pinger/src/main/java/org/hawkular/component/pinger/MetricPublisher.java
@@ -101,13 +101,17 @@ public void publishToTopic(String tenantId, List<SingleMetric> metrics) {
 
             try ( ConnectionContextFactory factory = new ConnectionContextFactory(connectionFactory)) {
 
+                Map<String,Object> outer = new HashMap<>(1);
+
                 Map<String,Object> data = new HashMap<>(2);
                 data.put("tenantId",tenantId);
                 data.put("data",metrics);
 
+                outer.put("metricData",data);
+
                 Endpoint endpoint = new Endpoint(Endpoint.Type.TOPIC,topic.getTopicName());
                 ProducerConnectionContext pc = factory.createProducerConnectionContext(endpoint);
-                BasicMessage msg = new ObjectMessage(data);
+                BasicMessage msg = new ObjectMessage(outer);
                 MessageProcessor processor = new MessageProcessor();
                 processor.send(pc, msg);
             }