X-Git-Url: https://git.octo.it/?p=collectd.git;a=blobdiff_plain;f=src%2Famqp.c;h=2077d57b3d5e870caa6e089456e646810c1e5ce7;hp=39575b93e68d52e2ba98e25716eac78b57d35e0f;hb=626d3ab4309cdb069289354c45ca9e2ba9bc9a2f;hpb=eada465ff40eb2ecaef17490e5462dab3b8874fe

diff --git a/src/amqp.c b/src/amqp.c
index 39575b93..2077d57b 100644
--- a/src/amqp.c
+++ b/src/amqp.c
@@ -320,17 +320,17 @@ static int camqp_setup_queue(camqp_config_t *conf) /* {{{ */
   amqp_queue_declare_ok_t *qd_ret;
   amqp_basic_consume_ok_t *cm_ret;
 
-  qd_ret = amqp_queue_declare(conf->connection,
-                              /* channel     = */ CAMQP_CHANNEL,
-                              /* queue       = */
-                                  (conf->queue != NULL)
-                                  ? amqp_cstring_bytes(conf->queue)
-                                  : AMQP_EMPTY_BYTES,
-                              /* passive     = */ 0,
-                              /* durable     = */ conf->queue_durable,
-                              /* exclusive   = */ 0,
-                              /* auto_delete = */ conf->queue_auto_delete,
-                              /* arguments   = */ AMQP_EMPTY_TABLE);
+  qd_ret =
+      amqp_queue_declare(conf->connection,
+                         /* channel     = */ CAMQP_CHANNEL,
+                         /* queue       = */
+                         (conf->queue != NULL) ? amqp_cstring_bytes(conf->queue)
+                                               : AMQP_EMPTY_BYTES,
+                         /* passive     = */ 0,
+                         /* durable     = */ conf->queue_durable,
+                         /* exclusive   = */ 0,
+                         /* auto_delete = */ conf->queue_auto_delete,
+                         /* arguments   = */ AMQP_EMPTY_TABLE);
   if (qd_ret == NULL) {
     ERROR("amqp plugin: amqp_queue_declare failed.");
     camqp_close_connection(conf);
@@ -360,8 +360,8 @@ static int camqp_setup_queue(camqp_config_t *conf) /* {{{ */
         /* queue       = */ amqp_cstring_bytes(conf->queue),
         /* exchange    = */ amqp_cstring_bytes(conf->exchange),
         /* routing_key = */
-            (conf->routing_key != NULL) ? amqp_cstring_bytes(conf->routing_key)
-                                        : AMQP_EMPTY_BYTES,
+        (conf->routing_key != NULL) ? amqp_cstring_bytes(conf->routing_key)
+                                    : AMQP_EMPTY_BYTES,
         /* arguments   = */ AMQP_EMPTY_TABLE);
     if ((qb_ret == NULL) && camqp_is_error(conf)) {
       char errbuf[1024];