X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Famqp.c;h=30a85810139fd489d2e440ad5e39fce220d1bbec;hb=d8825859c7b31f068899c2d5f8a147ea1ef65750;hp=adf4792b534b85f3219b6d5423bcc3c7c18a140a;hpb=081695d86026186373a76a4c6b6abacd21b3c3c6;p=collectd.git

diff --git a/src/amqp.c b/src/amqp.c
index adf4792b..30a85810 100644
--- a/src/amqp.c
+++ b/src/amqp.c
@@ -543,6 +543,8 @@ static void *camqp_subscribe_thread (void *user_data) /* {{{ */
     camqp_config_t *conf = user_data;
     int status;
 
+    cdtime_t interval = plugin_get_interval ();
+
     while (subscriber_threads_running)
     {
         amqp_frame_t frame;
@@ -552,8 +554,8 @@ static void *camqp_subscribe_thread (void *user_data) /* {{{ */
         {
             ERROR ("amqp plugin: camqp_connect failed. "
                     "Will sleep for %.3f seconds.",
-                    CDTIME_T_TO_DOUBLE (interval_g));
-            sleep (interval_g);
+                    CDTIME_T_TO_DOUBLE (interval));
+            sleep (interval);
             continue;
         }
 
@@ -562,9 +564,9 @@ static void *camqp_subscribe_thread (void *user_data) /* {{{ */
         {
             ERROR ("amqp plugin: amqp_simple_wait_frame failed. "
                     "Will sleep for %.3f seconds.",
-                    CDTIME_T_TO_DOUBLE (interval_g));
+                    CDTIME_T_TO_DOUBLE (interval));
             camqp_close_connection (conf);
-            sleep (interval_g);
+            sleep (interval);
             continue;
         }