X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Famqp.c;h=b237ba3dedcc1d451e81086e242bda88a038ec2b;hb=0a8741b9061f8df4a78a448c021612db06e17425;hp=882df7c576d0bc513afa54c87c18d58278b880c1;hpb=c442c66d9e98852f1b8eaa1b816d6ee7f84d0342;p=collectd.git

diff --git a/src/amqp.c b/src/amqp.c
index 882df7c5..b237ba3d 100644
--- a/src/amqp.c
+++ b/src/amqp.c
@@ -737,7 +737,7 @@ static int camqp_subscribe_init (camqp_config_t *conf) /* {{{ */
     memset (tmp, 0, sizeof (*tmp));
 
     status = plugin_thread_create (tmp, /* attr = */ NULL,
-            camqp_subscribe_thread, conf);
+            camqp_subscribe_thread, conf, "amqp subscribe");
     if (status != 0)
     {
         char errbuf[1024];
@@ -1015,6 +1015,9 @@ static int camqp_config_connection (oconfig_item_t *ci, /* {{{ */
         else if ((strcasecmp ("GraphiteAlwaysAppendDS", child->key) == 0) && publish)
             status = cf_util_get_flag (child, &conf->graphite_flags,
                     GRAPHITE_ALWAYS_APPEND_DS);
+        else if ((strcasecmp ("GraphitePreserveSeparator", child->key) == 0) && publish)
+            status = cf_util_get_flag (child, &conf->graphite_flags,
+                    GRAPHITE_PRESERVE_SEPARATOR);
         else if ((strcasecmp ("GraphitePrefix", child->key) == 0) && publish)
             status = cf_util_get_string (child, &conf->prefix);
         else if ((strcasecmp ("GraphitePostfix", child->key) == 0) && publish)