Initial code commit. It's really just a stub at this point to test out the

publishing interface for OpenTSDB. The publishing code is not thread safe.

Author: manolama

.gitignore

@@ -0,0 +1,12 @@
+INSTALL
+Makefile
+Makefile.in
+aclocal.m4
+autom4te.cache
+build
+target
+bin
+config.log
+config.status
+configure
+pom.xml

README.md

@@ -1,4 +1,6 @@
-opentsdb-rtpub-rabbitmq
-=======================
-
-Real Time publishing plugin for OpenTSDB
+opentsdb-rtpub-rabbitmq
+=======================
+
+Real Time publishing plugin for OpenTSDB
+
+This is just a stub and should NOT be used until it's cleaned up quite a bit.

src/META-INF/MANIFEST.MF

@@ -0,0 +1 @@
+Manifest-Version: 1.0

src/net/opentsdb/tsd/RabbitMQPublisherConfig.java

@@ -0,0 +1,28 @@
+package net.opentsdb.tsd;
+
+import java.util.Map;
+
+import net.opentsdb.utils.Config;
+
+public final class RabbitMQPublisherConfig extends Config {
+
+  public RabbitMQPublisherConfig(final Config parent) {
+    super(parent);
+  }
+  
+  @Override
+  protected void setDefaults() {
+    
+    default_map.put("tsd.rtpublisher.rabbitmq.hosts", "");
+    default_map.put("tsd.rtpublisher.rabbitmq.port", "5672");
+    default_map.put("tsd.rtpublisher.rabbitmq.user", "");
+    default_map.put("tsd.rtpublisher.rabbitmq.pass", "");
+    default_map.put("tsd.rtpublisher.rabbitmq.vhost", "opentsdb");
+    default_map.put("tsd.rtpublisher.rabbitmq.exchange.dps", "datapoints");
+    
+    for (Map.Entry<String, String> entry : default_map.entrySet()) {
+      if (!properties.containsKey(entry.getKey()))
+        properties.put(entry.getKey(), entry.getValue());
+    }
+  }
+}