X-Git-Url: https://git.octo.it/?p=collectd.git;a=blobdiff_plain;f=src%2Famqp.c;h=281130b142bd66f6f8664be5c02f5f3c92f0013f;hp=155792332e3803752d428c701608be03d9c43a6b;hb=06a86a60a7dabc685bdbd81ce3d36ea5f7e2c2d4;hpb=7b0628b4f4688d48d89f94ca381ca6340da05b37

diff --git a/src/amqp.c b/src/amqp.c
index 15579233..281130b1 100644
--- a/src/amqp.c
+++ b/src/amqp.c
@@ -111,8 +111,8 @@ static const char *def_user = "guest";
 static const char *def_password = "guest";
 static const char *def_exchange = "amq.fanout";
 
-static pthread_t *subscriber_threads = NULL;
-static size_t subscriber_threads_num = 0;
+static pthread_t *subscriber_threads;
+static size_t subscriber_threads_num;
 static bool subscriber_threads_running = true;
 
 #define CONF(c, f) (((c)->f != NULL) ? (c)->f : def_##f)
@@ -396,7 +396,7 @@ static int camqp_setup_queue(camqp_config_t *conf) /* {{{ */
 
 static int camqp_connect(camqp_config_t *conf) /* {{{ */
 {
-  static time_t last_connect_time = 0;
+  static time_t last_connect_time;
 
   amqp_rpc_reply_t reply;
   int status;