X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Famqp.c;h=97359cfd394facc2fa81669385c3bedecd019d98;hb=871b643dc18d7ffe0ba8334dc5fb222741433774;hp=dd5a65267a1212622b2b66097a01e650c6fe8a99;hpb=5acbb982f1c16b1abb0f088698d7165327718fd4;p=collectd.git

diff --git a/src/amqp.c b/src/amqp.c
index dd5a6526..97359cfd 100644
--- a/src/amqp.c
+++ b/src/amqp.c
@@ -304,6 +304,10 @@ static int camqp_create_exchange (camqp_config_t *conf) /* {{{ */
             /* type        = */ amqp_cstring_bytes (conf->exchange_type),
             /* passive     = */ 0,
             /* durable     = */ 0,
+#if defined(AMQP_VERSION) && AMQP_VERSION >= 0x00060000
+            /* auto delete = */ 0,
+            /* internal    = */ 0,
+#endif
             /* arguments   = */ argument_table);
     if ((ed_ret == NULL) && camqp_is_error (conf))
     {
@@ -408,7 +412,7 @@ static int camqp_setup_queue (camqp_config_t *conf) /* {{{ */
 
 static int camqp_connect (camqp_config_t *conf) /* {{{ */
 {
-    static time_t lastConnectTime = 0;
+    static time_t last_connect_time = 0;
 
     amqp_rpc_reply_t reply;
     int status;
@@ -422,16 +426,16 @@ static int camqp_connect (camqp_config_t *conf) /* {{{ */
         return (0);
 
     time_t now = time(NULL);
-    if (now < (lastConnectTime + conf->connection_retry_delay))
+    if (now < (last_connect_time + conf->connection_retry_delay))
     {
-        DEBUG("amqp plugin: skipping connection retry, ConnectionRetryDelay: %d"
-                , conf->connection_retry_delay);
+        DEBUG("amqp plugin: skipping connection retry, "
+            "ConnectionRetryDelay: %d", conf->connection_retry_delay);
         return(1);
     }
     else
     {
         DEBUG ("amqp plugin: retrying connection");
-        lastConnectTime = now;
+        last_connect_time = now;
     }
 
     conf->connection = amqp_new_connection ();
@@ -940,7 +944,7 @@ static int camqp_config_connection (oconfig_item_t *ci, /* {{{ */
     conf->password = NULL;
     conf->exchange = NULL;
     conf->routing_key = NULL;
-    conf->connection_retry_delay = 60;
+    conf->connection_retry_delay = 0;
 
     /* publish only */
     conf->delivery_mode = CAMQP_DM_VOLATILE;