Format code with clang-format

22 files changed, 398 insertions, 376 deletions

diff --git a/examples/amqp_bind.c b/examples/amqp_bind.c
index fecbaff..46371a4 100644
--- a/examples/amqp_bind.c
+++ b/examples/amqp_bind.c
@@ -34,8 +34,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -43,8 +43,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -76,20 +75,21 @@ int main(int argc, char const *const *argv)
     die("opening TCP socket");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
-  amqp_queue_bind(conn, 1,
-                  amqp_cstring_bytes(queue),
-                  amqp_cstring_bytes(exchange),
-                  amqp_cstring_bytes(bindingkey),
+  amqp_queue_bind(conn, 1, amqp_cstring_bytes(queue),
+                  amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey),
                   amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Unbinding");
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/amqp_connect_timeout.c b/examples/amqp_connect_timeout.c
index 2f0fb97..21bd02e 100644
--- a/examples/amqp_connect_timeout.c
+++ b/examples/amqp_connect_timeout.c
@@ -37,8 +37,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -47,18 +47,17 @@
 #include <assert.h>
 
 #ifdef _WIN32
-# ifndef WIN32_LEAN_AND_MEAN
-#  define WIN32_LEAN_AND_MEAN
-# endif
-# include <Winsock2.h>
+#ifndef WIN32_LEAN_AND_MEAN
+#define WIN32_LEAN_AND_MEAN
+#endif
+#include <Winsock2.h>
 #else
-# include <sys/time.h>
+#include <sys/time.h>
 #endif
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port;
   amqp_socket_t *socket;
@@ -67,7 +66,9 @@ int main(int argc, char const *const *argv)
   struct timeval *tv;
 
   if (argc < 3) {
-    fprintf(stderr, "Usage: amqp_connect_timeout host port [timeout_sec [timeout_usec=0]]\n");
+    fprintf(stderr,
+            "Usage: amqp_connect_timeout host port [timeout_sec "
+            "[timeout_usec=0]]\n");
     return 1;
   }
 
@@ -76,7 +77,7 @@ int main(int argc, char const *const *argv)
 
     tv->tv_sec = atoi(argv[3]);
 
-    if (argc > 4 ) {
+    if (argc > 4) {
       tv->tv_usec = atoi(argv[4]);
     } else {
       tv->tv_usec = 0;
@@ -86,7 +87,6 @@ int main(int argc, char const *const *argv)
     tv = NULL;
   }
 
-
   hostname = argv[1];
   port = atoi(argv[2]);
 
@@ -98,13 +98,17 @@ int main(int argc, char const *const *argv)
     die("creating TCP socket");
   }
 
-  die_on_error(amqp_socket_open_noblock(socket, hostname, port, tv), "opening TCP socket");
+  die_on_error(amqp_socket_open_noblock(socket, hostname, port, tv),
+               "opening TCP socket");
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"), "Logging in");
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
+                    "Logging in");
 
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
 
-  printf ("Done\n");
+  printf("Done\n");
   return 0;
 }
diff --git a/examples/amqp_consumer.c b/examples/amqp_consumer.c
index 189f874..93c7a21 100644
--- a/examples/amqp_consumer.c
+++ b/examples/amqp_consumer.c
@@ -34,8 +34,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -47,8 +47,7 @@
 
 #define SUMMARY_EVERY_US 1000000
 
-static void run(amqp_connection_state_t conn)
-{
+static void run(amqp_connection_state_t conn) {
   uint64_t start_time = now_microseconds();
   int received = 0;
   int previous_received = 0;
@@ -66,9 +65,11 @@ static void run(amqp_connection_state_t conn)
     now = now_microseconds();
     if (now > next_summary_time) {
       int countOverInterval = received - previous_received;
-      double intervalRate = countOverInterval / ((now - previous_report_time) / 1000000.0);
+      double intervalRate =
+          countOverInterval / ((now - previous_report_time) / 1000000.0);
       printf("%d ms: Received %d - %d since last report (%d Hz)\n",
-             (int)(now - start_time) / 1000, received, countOverInterval, (int) intervalRate);
+             (int)(now - start_time) / 1000, received, countOverInterval,
+             (int)intervalRate);
 
       previous_received = received;
       previous_report_time = now;
@@ -88,14 +89,14 @@ static void run(amqp_connection_state_t conn)
         if (AMQP_FRAME_METHOD == frame.frame_type) {
           switch (frame.payload.method.id) {
             case AMQP_BASIC_ACK_METHOD:
-              /* if we've turned publisher confirms on, and we've published a message
-               * here is a message being confirmed
+              /* if we've turned publisher confirms on, and we've published a
+               * message here is a message being confirmed.
                */
-
               break;
             case AMQP_BASIC_RETURN_METHOD:
-              /* if a published message couldn't be routed and the mandatory flag was set
-               * this is what would be returned. The message then needs to be read.
+              /* if a published message couldn't be routed and the mandatory
+               * flag was set this is what would be returned. The message then
+               * needs to be read.
                */
               {
                 amqp_message_t message;
@@ -110,25 +111,28 @@ static void run(amqp_connection_state_t conn)
               break;
 
             case AMQP_CHANNEL_CLOSE_METHOD:
-              /* a channel.close method happens when a channel exception occurs, this
-               * can happen by publishing to an exchange that doesn't exist for example
+              /* a channel.close method happens when a channel exception occurs,
+               * this can happen by publishing to an exchange that doesn't exist
+               * for example.
                *
-               * In this case you would need to open another channel redeclare any queues
-               * that were declared auto-delete, and restart any consumers that were attached
-               * to the previous channel
+               * In this case you would need to open another channel redeclare
+               * any queues that were declared auto-delete, and restart any
+               * consumers that were attached to the previous channel.
                */
               return;
 
             case AMQP_CONNECTION_CLOSE_METHOD:
-              /* a connection.close method happens when a connection exception occurs,
-               * this can happen by trying to use a channel that isn't open for example.
+              /* a connection.close method happens when a connection exception
+               * occurs, this can happen by trying to use a channel that isn't
+               * open for example.
                *
                * In this case the whole connection must be restarted.
                */
               return;
 
             default:
-              fprintf(stderr ,"An unexpected method was received %u\n", frame.payload.method.id);
+              fprintf(stderr, "An unexpected method was received %u\n",
+                      frame.payload.method.id);
               return;
           }
         }
@@ -142,8 +146,7 @@ static void run(amqp_connection_state_t conn)
   }
 }
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -160,7 +163,7 @@ int main(int argc, char const *const *argv)
 
   hostname = argv[1];
   port = atoi(argv[2]);
-  exchange = "amq.direct"; /* argv[3]; */
+  exchange = "amq.direct";   /* argv[3]; */
   bindingkey = "test queue"; /* argv[4]; */
 
   conn = amqp_new_connection();
@@ -175,14 +178,15 @@ int main(int argc, char const *const *argv)
     die("opening TCP socket");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   {
-    amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, amqp_empty_bytes, 0, 0, 0, 1,
-                                 amqp_empty_table);
+    amqp_queue_declare_ok_t *r = amqp_queue_declare(
+        conn, 1, amqp_empty_bytes, 0, 0, 0, 1, amqp_empty_table);
     die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring queue");
     queuename = amqp_bytes_malloc_dup(r->queue);
     if (queuename.bytes == NULL) {
@@ -191,17 +195,20 @@ int main(int argc, char const *const *argv)
     }
   }
 
-  amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey),
-                  amqp_empty_table);
+  amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange),
+                  amqp_cstring_bytes(bindingkey), amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Binding queue");
 
-  amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0, amqp_empty_table);
+  amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0,
+                     amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming");
 
   run(conn);
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
 
   return 0;
diff --git a/examples/amqp_exchange_declare.c b/examples/amqp_exchange_declare.c
index a120975..2199a0b 100644
--- a/examples/amqp_exchange_declare.c
+++ b/examples/amqp_exchange_declare.c
@@ -34,8 +34,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -43,8 +43,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -53,7 +52,8 @@ int main(int argc, char const *const *argv)
   amqp_connection_state_t conn;
 
   if (argc < 5) {
-    fprintf(stderr, "Usage: amqp_exchange_declare host port exchange exchangetype\n");
+    fprintf(stderr,
+            "Usage: amqp_exchange_declare host port exchange exchangetype\n");
     return 1;
   }
 
@@ -74,17 +74,21 @@ int main(int argc, char const *const *argv)
     die("opening TCP socket");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
-  amqp_exchange_declare(conn, 1, amqp_cstring_bytes(exchange), amqp_cstring_bytes(exchangetype),
-                        0, 0, 0, 0, amqp_empty_table);
+  amqp_exchange_declare(conn, 1, amqp_cstring_bytes(exchange),
+                        amqp_cstring_bytes(exchangetype), 0, 0, 0, 0,
+                        amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring exchange");
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/amqp_listen.c b/examples/amqp_listen.c
index bee037c..9026226 100644
--- a/examples/amqp_listen.c
+++ b/examples/amqp_listen.c
@@ -34,8 +34,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -45,8 +45,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -78,14 +77,15 @@ int main(int argc, char const *const *argv)
     die("opening TCP socket");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   {
-    amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, amqp_empty_bytes, 0, 0, 0, 1,
-                                 amqp_empty_table);
+    amqp_queue_declare_ok_t *r = amqp_queue_declare(
+        conn, 1, amqp_empty_bytes, 0, 0, 0, 1, amqp_empty_table);
     die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring queue");
     queuename = amqp_bytes_malloc_dup(r->queue);
     if (queuename.bytes == NULL) {
@@ -94,11 +94,12 @@ int main(int argc, char const *const *argv)
     }
   }
 
-  amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey),
-                  amqp_empty_table);
+  amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange),
+                  amqp_cstring_bytes(bindingkey), amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Binding queue");
 
-  amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0, amqp_empty_table);
+  amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0,
+                     amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming");
 
   {
@@ -115,14 +116,14 @@ int main(int argc, char const *const *argv)
       }
 
       printf("Delivery %u, exchange %.*s routingkey %.*s\n",
-             (unsigned) envelope.delivery_tag,
-             (int) envelope.exchange.len, (char *) envelope.exchange.bytes,
-             (int) envelope.routing_key.len, (char *) envelope.routing_key.bytes);
+             (unsigned)envelope.delivery_tag, (int)envelope.exchange.len,
+             (char *)envelope.exchange.bytes, (int)envelope.routing_key.len,
+             (char *)envelope.routing_key.bytes);
 
       if (envelope.message.properties._flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
         printf("Content-type: %.*s\n",
-               (int) envelope.message.properties.content_type.len,
-               (char *) envelope.message.properties.content_type.bytes);
+               (int)envelope.message.properties.content_type.len,
+               (char *)envelope.message.properties.content_type.bytes);
       }
       printf("----\n");
 
@@ -132,8 +133,10 @@ int main(int argc, char const *const *argv)
     }
   }
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
 
   return 0;
diff --git a/examples/amqp_listenq.c b/examples/amqp_listenq.c
index 3b83494..624dc5c 100644
--- a/examples/amqp_listenq.c
+++ b/examples/amqp_listenq.c
@@ -34,8 +34,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -45,8 +45,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *queuename;
@@ -74,12 +73,14 @@ int main(int argc, char const *const *argv)
     die("opening TCP socket");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
-  amqp_basic_consume(conn, 1, amqp_cstring_bytes(queuename), amqp_empty_bytes, 0, 0, 0, amqp_empty_table);
+  amqp_basic_consume(conn, 1, amqp_cstring_bytes(queuename), amqp_empty_bytes,
+                     0, 0, 0, amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming");
 
   for (;;) {
@@ -95,14 +96,14 @@ int main(int argc, char const *const *argv)
     }
 
     printf("Delivery %u, exchange %.*s routingkey %.*s\n",
-           (unsigned) envelope.delivery_tag,
-           (int) envelope.exchange.len, (char *) envelope.exchange.bytes,
-           (int) envelope.routing_key.len, (char *) envelope.routing_key.bytes);
+           (unsigned)envelope.delivery_tag, (int)envelope.exchange.len,
+           (char *)envelope.exchange.bytes, (int)envelope.routing_key.len,
+           (char *)envelope.routing_key.bytes);
 
     if (envelope.message.properties._flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
       printf("Content-type: %.*s\n",
-             (int) envelope.message.properties.content_type.len,
-             (char *) envelope.message.properties.content_type.bytes);
+             (int)envelope.message.properties.content_type.len,
+             (char *)envelope.message.properties.content_type.bytes);
     }
     printf("----\n");
 
@@ -111,8 +112,10 @@ int main(int argc, char const *const *argv)
     amqp_destroy_envelope(&envelope);
   }
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
 
   return 0;
diff --git a/examples/amqp_producer.c b/examples/amqp_producer.c
index c535fb6..6e78fcb 100644
--- a/examples/amqp_producer.c
+++ b/examples/amqp_producer.c
@@ -34,8 +34,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -45,11 +45,8 @@
 
 #define SUMMARY_EVERY_US 1000000
 
-static void send_batch(amqp_connection_state_t conn,
-                       char const *queue_name,
-                       int rate_limit,
-                       int message_count)
-{
+static void send_batch(amqp_connection_state_t conn, char const *queue_name,
+                       int rate_limit, int message_count) {
   uint64_t start_time = now_microseconds();
   int i;
   int sent = 0;
@@ -70,21 +67,18 @@ static void send_batch(amqp_connection_state_t conn,
   for (i = 0; i < message_count; i++) {
     uint64_t now = now_microseconds();
 
-    die_on_error(amqp_basic_publish(conn,
-                                    1,
-                                    amqp_cstring_bytes("amq.direct"),
-                                    amqp_cstring_bytes(queue_name),
-                                    0,
-                                    0,
-                                    NULL,
+    die_on_error(amqp_basic_publish(conn, 1, amqp_cstring_bytes("amq.direct"),
+                                    amqp_cstring_bytes(queue_name), 0, 0, NULL,
                                     message_bytes),
                  "Publishing");
     sent++;
     if (now > next_summary_time) {
       int countOverInterval = sent - previous_sent;
-      double intervalRate = countOverInterval / ((now - previous_report_time) / 1000000.0);
+      double intervalRate =
+          countOverInterval / ((now - previous_report_time) / 1000000.0);
       printf("%d ms: Sent %d - %d since last report (%d Hz)\n",
-             (int)(now - start_time) / 1000, sent, countOverInterval, (int) intervalRate);
+             (int)(now - start_time) / 1000, sent, countOverInterval,
+             (int)intervalRate);
 
       previous_sent = sent;
       previous_report_time = now;
@@ -103,12 +97,12 @@ static void send_batch(amqp_connection_state_t conn,
 
     printf("PRODUCER - Message count: %d\n", message_count);
     printf("Total time, milliseconds: %d\n", total_delta / 1000);
-    printf("Overall messages-per-second: %g\n", (message_count / (total_delta / 1000000.0)));
+    printf("Overall messages-per-second: %g\n",
+           (message_count / (total_delta / 1000000.0)));
   }
 }
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   int rate_limit;
@@ -117,7 +111,8 @@ int main(int argc, char const *const *argv)
   amqp_connection_state_t conn;
 
   if (argc < 5) {
-    fprintf(stderr, "Usage: amqp_producer host port rate_limit message_count\n");
+    fprintf(stderr,
+            "Usage: amqp_producer host port rate_limit message_count\n");
     return 1;
   }
 
@@ -138,15 +133,18 @@ int main(int argc, char const *const *argv)
     die("opening TCP socket");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   send_batch(conn, "test queue", rate_limit, message_count);
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/amqp_rpc_sendstring_client.c b/examples/amqp_rpc_sendstring_client.c
index 8c322a6..59918e5 100644
--- a/examples/amqp_rpc_sendstring_client.c
+++ b/examples/amqp_rpc_sendstring_client.c
@@ -34,8 +34,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -45,8 +45,7 @@
 
 #include "utils.h"
 
-int main(int argc, char *argv[])
-{
+int main(int argc, char *argv[]) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -57,7 +56,9 @@ int main(int argc, char *argv[])
   amqp_bytes_t reply_to_queue;
 
   if (argc < 6) { /* minimum number of mandatory arguments */
-    fprintf(stderr, "usage:\namqp_rpc_sendstring_client host port exchange routingkey messagebody\n");
+    fprintf(stderr,
+            "usage:\namqp_rpc_sendstring_client host port exchange routingkey "
+            "messagebody\n");
     return 1;
   }
 
@@ -83,7 +84,8 @@ int main(int argc, char *argv[])
     die("opening TCP socket");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
@@ -93,7 +95,8 @@ int main(int argc, char *argv[])
   */
 
   {
-    amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, amqp_empty_bytes, 0, 0, 0, 1, amqp_empty_table);
+    amqp_queue_declare_ok_t *r = amqp_queue_declare(
+        conn, 1, amqp_empty_bytes, 0, 0, 0, 1, amqp_empty_table);
     die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring queue");
     reply_to_queue = amqp_bytes_malloc_dup(r->queue);
     if (reply_to_queue.bytes == NULL) {
@@ -112,8 +115,7 @@ int main(int argc, char *argv[])
     */
     amqp_basic_properties_t props;
     props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG |
-                   AMQP_BASIC_DELIVERY_MODE_FLAG |
-                   AMQP_BASIC_REPLY_TO_FLAG |
+                   AMQP_BASIC_DELIVERY_MODE_FLAG | AMQP_BASIC_REPLY_TO_FLAG |
                    AMQP_BASIC_CORRELATION_ID_FLAG;
     props.content_type = amqp_cstring_bytes("text/plain");
     props.delivery_mode = 2; /* persistent delivery mode */
@@ -127,14 +129,9 @@ int main(int argc, char *argv[])
     /*
       publish
     */
-    die_on_error(amqp_basic_publish(conn,
-                                    1,
-                                    amqp_cstring_bytes(exchange),
-                                    amqp_cstring_bytes(routingkey),
-                                    0,
-                                    0,
-                                    &props,
-                                    amqp_cstring_bytes(messagebody)),
+    die_on_error(amqp_basic_publish(conn, 1, amqp_cstring_bytes(exchange),
+                                    amqp_cstring_bytes(routingkey), 0, 0,
+                                    &props, amqp_cstring_bytes(messagebody)),
                  "Publishing");
 
     amqp_bytes_free(props.reply_to);
@@ -145,7 +142,8 @@ int main(int argc, char *argv[])
   */
 
   {
-    amqp_basic_consume(conn, 1, reply_to_queue, amqp_empty_bytes, 0, 1, 0, amqp_empty_table);
+    amqp_basic_consume(conn, 1, reply_to_queue, amqp_empty_bytes, 0, 1, 0,
+                       amqp_empty_table);
     die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming");
     amqp_bytes_free(reply_to_queue);
 
@@ -176,11 +174,11 @@ int main(int argc, char *argv[])
           continue;
         }
 
-        d = (amqp_basic_deliver_t *) frame.payload.method.decoded;
+        d = (amqp_basic_deliver_t *)frame.payload.method.decoded;
         printf("Delivery: %u exchange: %.*s routingkey: %.*s\n",
-               (unsigned) d->delivery_tag,
-               (int) d->exchange.len, (char *) d->exchange.bytes,
-               (int) d->routing_key.len, (char *) d->routing_key.bytes);
+               (unsigned)d->delivery_tag, (int)d->exchange.len,
+               (char *)d->exchange.bytes, (int)d->routing_key.len,
+               (char *)d->routing_key.bytes);
 
         result = amqp_simple_wait_frame(conn, &frame);
         if (result < 0) {
@@ -191,10 +189,10 @@ int main(int argc, char *argv[])
           fprintf(stderr, "Expected header!");
           abort();
         }
-        p = (amqp_basic_properties_t *) frame.payload.properties.decoded;
+        p = (amqp_basic_properties_t *)frame.payload.properties.decoded;
         if (p->_flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
-          printf("Content-type: %.*s\n",
-                 (int) p->content_type.len, (char *) p->content_type.bytes);
+          printf("Content-type: %.*s\n", (int)p->content_type.len,
+                 (char *)p->content_type.bytes);
         }
         printf("----\n");
 
@@ -228,7 +226,6 @@ int main(int argc, char *argv[])
         /* everything was fine, we can quit now because we received the reply */
         break;
       }
-
     }
   }
 
@@ -236,8 +233,10 @@ int main(int argc, char *argv[])
      closing
   */
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
 
   return 0;
diff --git a/examples/amqp_sendstring.c b/examples/amqp_sendstring.c
index 22c033d..75492aa 100644
--- a/examples/amqp_sendstring.c
+++ b/examples/amqp_sendstring.c
@@ -34,8 +34,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -43,8 +43,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -54,7 +53,9 @@ int main(int argc, char const *const *argv)
   amqp_connection_state_t conn;
 
   if (argc < 6) {
-    fprintf(stderr, "Usage: amqp_sendstring host port exchange routingkey messagebody\n");
+    fprintf(
+        stderr,
+        "Usage: amqp_sendstring host port exchange routingkey messagebody\n");
     return 1;
   }
 
@@ -76,7 +77,8 @@ int main(int argc, char const *const *argv)
     die("opening TCP socket");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
@@ -86,19 +88,16 @@ int main(int argc, char const *const *argv)
     props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | AMQP_BASIC_DELIVERY_MODE_FLAG;
     props.content_type = amqp_cstring_bytes("text/plain");
     props.delivery_mode = 2; /* persistent delivery mode */
-    die_on_error(amqp_basic_publish(conn,
-                                    1,
-                                    amqp_cstring_bytes(exchange),
-                                    amqp_cstring_bytes(routingkey),
-                                    0,
-                                    0,
-                                    &props,
-                                    amqp_cstring_bytes(messagebody)),
+    die_on_error(amqp_basic_publish(conn, 1, amqp_cstring_bytes(exchange),
+                                    amqp_cstring_bytes(routingkey), 0, 0,
+                                    &props, amqp_cstring_bytes(messagebody)),
                  "Publishing");
   }
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/amqp_unbind.c b/examples/amqp_unbind.c
index 6a746b8..aea0738 100644
--- a/examples/amqp_unbind.c
+++ b/examples/amqp_unbind.c
@@ -34,8 +34,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -43,8 +43,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -76,20 +75,21 @@ int main(int argc, char const *const *argv)
     die("opening TCP socket");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
-  amqp_queue_unbind(conn, 1,
-                    amqp_cstring_bytes(queue),
+  amqp_queue_unbind(conn, 1, amqp_cstring_bytes(queue),
                     amqp_cstring_bytes(exchange),
-                    amqp_cstring_bytes(bindingkey),
-                    amqp_empty_table);
+                    amqp_cstring_bytes(bindingkey), amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Unbinding");
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/amqps_bind.c b/examples/amqps_bind.c
index c1785af..8832566 100644
--- a/examples/amqps_bind.c
+++ b/examples/amqps_bind.c
@@ -37,8 +37,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -46,8 +46,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -57,7 +56,8 @@ int main(int argc, char const *const *argv)
   amqp_connection_state_t conn;
 
   if (argc < 6) {
-    fprintf(stderr, "Usage: amqps_bind host port exchange bindingkey queue "
+    fprintf(stderr,
+            "Usage: amqps_bind host port exchange bindingkey queue "
             "[cacert.pem [verifypeer] [verifyhostname] [key.pem cert.pem]]\n");
     return 1;
   }
@@ -106,20 +106,21 @@ int main(int argc, char const *const *argv)
     die("opening SSL/TLS connection");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
-  amqp_queue_bind(conn, 1,
-                  amqp_cstring_bytes(queue),
-                  amqp_cstring_bytes(exchange),
-                  amqp_cstring_bytes(bindingkey),
+  amqp_queue_bind(conn, 1, amqp_cstring_bytes(queue),
+                  amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey),
                   amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Unbinding");
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/amqps_connect_timeout.c b/examples/amqps_connect_timeout.c
index 0dbbebc..e41b00a 100644
--- a/examples/amqps_connect_timeout.c
+++ b/examples/amqps_connect_timeout.c
@@ -40,8 +40,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -50,19 +50,17 @@
 #include <assert.h>
 
 #ifdef _WIN32
-# ifndef WIN32_LEAN_AND_MEAN
-#  define WIN32_LEAN_AND_MEAN
-# endif
-# include <Winsock2.h>
+#ifndef WIN32_LEAN_AND_MEAN
+#define WIN32_LEAN_AND_MEAN
+#endif
+#include <Winsock2.h>
 #else
-# include <sys/time.h>
+#include <sys/time.h>
 #endif
 
 #include "utils.h"
 
-
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port;
   int timeout;
@@ -72,10 +70,9 @@ int main(int argc, char const *const *argv)
   struct timeval *tv;
 
   if (argc < 3) {
-    fprintf(
-        stderr,
-        "Usage: amqps_connect_timeout host port timeout_sec "
-        "[cacert.pem [verifypeer] [verifyhostname] [key.pem cert.pem]]\n");
+    fprintf(stderr,
+            "Usage: amqps_connect_timeout host port timeout_sec "
+            "[cacert.pem [verifypeer] [verifyhostname] [key.pem cert.pem]]\n");
     return 1;
   }
 
@@ -121,14 +118,17 @@ int main(int argc, char const *const *argv)
     }
   }
 
-  die_on_error(amqp_socket_open_noblock(socket, hostname, port, tv), "opening SSL/TLS connection");
+  die_on_error(amqp_socket_open_noblock(socket, hostname, port, tv),
+               "opening SSL/TLS connection");
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
 
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
 
-  printf ("Done\n");
+  printf("Done\n");
   return 0;
 }
diff --git a/examples/amqps_consumer.c b/examples/amqps_consumer.c
index cc0a270..50013e3 100644
--- a/examples/amqps_consumer.c
+++ b/examples/amqps_consumer.c
@@ -37,8 +37,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -50,8 +50,7 @@
 
 #define SUMMARY_EVERY_US 1000000
 
-static void run(amqp_connection_state_t conn)
-{
+static void run(amqp_connection_state_t conn) {
   uint64_t start_time = now_microseconds();
   int received = 0;
   int previous_received = 0;
@@ -69,9 +68,11 @@ static void run(amqp_connection_state_t conn)
     now = now_microseconds();
     if (now > next_summary_time) {
       int countOverInterval = received - previous_received;
-      double intervalRate = countOverInterval / ((now - previous_report_time) / 1000000.0);
+      double intervalRate =
+          countOverInterval / ((now - previous_report_time) / 1000000.0);
       printf("%d ms: Received %d - %d since last report (%d Hz)\n",
-             (int)(now - start_time) / 1000, received, countOverInterval, (int) intervalRate);
+             (int)(now - start_time) / 1000, received, countOverInterval,
+             (int)intervalRate);
 
       previous_received = received;
       previous_report_time = now;
@@ -91,14 +92,15 @@ static void run(amqp_connection_state_t conn)
         if (AMQP_FRAME_METHOD == frame.frame_type) {
           switch (frame.payload.method.id) {
             case AMQP_BASIC_ACK_METHOD:
-              /* if we've turned publisher confirms on, and we've published a message
-               * here is a message being confirmed
+              /* if we've turned publisher confirms on, and we've published a
+               * message here is a message being confirmed.
                */
 
               break;
             case AMQP_BASIC_RETURN_METHOD:
-              /* if a published message couldn't be routed and the mandatory flag was set
-               * this is what would be returned. The message then needs to be read.
+              /* if a published message couldn't be routed and the mandatory
+               * flag was set this is what would be returned. The message then
+               * needs to be read.
                */
               {
                 amqp_message_t message;
@@ -113,25 +115,28 @@ static void run(amqp_connection_state_t conn)
               break;
 
             case AMQP_CHANNEL_CLOSE_METHOD:
-              /* a channel.close method happens when a channel exception occurs, this
-               * can happen by publishing to an exchange that doesn't exist for example
+              /* a channel.close method happens when a channel exception occurs,
+               * this can happen by publishing to an exchange that doesn't exist
+               * for example.
                *
-               * In this case you would need to open another channel redeclare any queues
-               * that were declared auto-delete, and restart any consumers that were attached
-               * to the previous channel
+               * In this case you would need to open another channel redeclare
+               * any queues that were declared auto-delete, and restart any
+               * consumers that were attached to the previous channel.
                */
               return;
 
             case AMQP_CONNECTION_CLOSE_METHOD:
-              /* a connection.close method happens when a connection exception occurs,
-               * this can happen by trying to use a channel that isn't open for example.
+              /* a connection.close method happens when a connection exception
+               * occurs, this can happen by trying to use a channel that isn't
+               * open for example.
                *
                * In this case the whole connection must be restarted.
                */
               return;
 
             default:
-              fprintf(stderr ,"An unexpected method was received %u\n", frame.payload.method.id);
+              fprintf(stderr, "An unexpected method was received %u\n",
+                      frame.payload.method.id);
               return;
           }
         }
@@ -141,13 +146,11 @@ static void run(amqp_connection_state_t conn)
       amqp_destroy_envelope(&envelope);
     }
 
-
     received++;
   }
 }
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -157,14 +160,15 @@ int main(int argc, char const *const *argv)
   amqp_bytes_t queuename;
 
   if (argc < 3) {
-    fprintf(stderr, "Usage: amqps_consumer host port "
+    fprintf(stderr,
+            "Usage: amqps_consumer host port "
             "[cacert.pem [verifypeer] [verifyhostname] [key.pem cert.pem]]\n");
     return 1;
   }
 
   hostname = argv[1];
   port = atoi(argv[2]);
-  exchange = "amq.direct"; /* argv[3]; */
+  exchange = "amq.direct";   /* argv[3]; */
   bindingkey = "test queue"; /* argv[4]; */
 
   conn = amqp_new_connection();
@@ -205,14 +209,15 @@ int main(int argc, char const *const *argv)
     die("opening SSL/TLS connection");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   {
-    amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, amqp_empty_bytes, 0, 0, 0, 1,
-                                 amqp_empty_table);
+    amqp_queue_declare_ok_t *r = amqp_queue_declare(
+        conn, 1, amqp_empty_bytes, 0, 0, 0, 1, amqp_empty_table);
     die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring queue");
     queuename = amqp_bytes_malloc_dup(r->queue);
     if (queuename.bytes == NULL) {
@@ -221,17 +226,20 @@ int main(int argc, char const *const *argv)
     }
   }
 
-  amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey),
-                  amqp_empty_table);
+  amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange),
+                  amqp_cstring_bytes(bindingkey), amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Binding queue");
 
-  amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0, amqp_empty_table);
+  amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0,
+                     amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming");
 
   run(conn);
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
 
   return 0;
diff --git a/examples/amqps_exchange_declare.c b/examples/amqps_exchange_declare.c
index 77de26b..1436e0c 100644
--- a/examples/amqps_exchange_declare.c
+++ b/examples/amqps_exchange_declare.c
@@ -37,8 +37,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -46,8 +46,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -56,7 +55,8 @@ int main(int argc, char const *const *argv)
   amqp_connection_state_t conn;
 
   if (argc < 5) {
-    fprintf(stderr, "Usage: amqps_exchange_declare host port exchange "
+    fprintf(stderr,
+            "Usage: amqps_exchange_declare host port exchange "
             "exchangetype [cacert.pem [verifypeer] [verifyhostname] "
             "[key.pem cert.pem]]\n");
     return 1;
@@ -105,17 +105,21 @@ int main(int argc, char const *const *argv)
     die("opening SSL/TLS connection");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
-  amqp_exchange_declare(conn, 1, amqp_cstring_bytes(exchange), amqp_cstring_bytes(exchangetype),
-                        0, 0, 0, 0, amqp_empty_table);
+  amqp_exchange_declare(conn, 1, amqp_cstring_bytes(exchange),
+                        amqp_cstring_bytes(exchangetype), 0, 0, 0, 0,
+                        amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring exchange");
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/amqps_listen.c b/examples/amqps_listen.c
index b609846..5d12bbf 100644
--- a/examples/amqps_listen.c
+++ b/examples/amqps_listen.c
@@ -37,8 +37,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -48,8 +48,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -60,7 +59,8 @@ int main(int argc, char const *const *argv)
   amqp_bytes_t queuename;
 
   if (argc < 5) {
-    fprintf(stderr, "Usage: amqps_listen host port exchange bindingkey "
+    fprintf(stderr,
+            "Usage: amqps_listen host port exchange bindingkey "
             "[cacert.pem [verifypeer] [verifyhostname] [key.pem cert.pem]]\n");
     return 1;
   }
@@ -103,20 +103,20 @@ int main(int argc, char const *const *argv)
     }
   }
 
-
   status = amqp_socket_open(socket, hostname, port);
   if (status) {
     die("opening SSL/TLS connection");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   {
-    amqp_queue_declare_ok_t *r = amqp_queue_declare(conn, 1, amqp_empty_bytes, 0, 0, 0, 1,
-                                 amqp_empty_table);
+    amqp_queue_declare_ok_t *r = amqp_queue_declare(
+        conn, 1, amqp_empty_bytes, 0, 0, 0, 1, amqp_empty_table);
     die_on_amqp_error(amqp_get_rpc_reply(conn), "Declaring queue");
     queuename = amqp_bytes_malloc_dup(r->queue);
     if (queuename.bytes == NULL) {
@@ -125,11 +125,12 @@ int main(int argc, char const *const *argv)
     }
   }
 
-  amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange), amqp_cstring_bytes(bindingkey),
-                  amqp_empty_table);
+  amqp_queue_bind(conn, 1, queuename, amqp_cstring_bytes(exchange),
+                  amqp_cstring_bytes(bindingkey), amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Binding queue");
 
-  amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0, amqp_empty_table);
+  amqp_basic_consume(conn, 1, queuename, amqp_empty_bytes, 0, 1, 0,
+                     amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming");
 
   {
@@ -146,14 +147,14 @@ int main(int argc, char const *const *argv)
       }
 
       printf("Delivery %u, exchange %.*s routingkey %.*s\n",
-             (unsigned) envelope.delivery_tag,
-             (int) envelope.exchange.len, (char *) envelope.exchange.bytes,
-             (int) envelope.routing_key.len, (char *) envelope.routing_key.bytes);
+             (unsigned)envelope.delivery_tag, (int)envelope.exchange.len,
+             (char *)envelope.exchange.bytes, (int)envelope.routing_key.len,
+             (char *)envelope.routing_key.bytes);
 
       if (envelope.message.properties._flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
         printf("Content-type: %.*s\n",
-               (int) envelope.message.properties.content_type.len,
-               (char *) envelope.message.properties.content_type.bytes);
+               (int)envelope.message.properties.content_type.len,
+               (char *)envelope.message.properties.content_type.bytes);
       }
       printf("----\n");
 
@@ -163,8 +164,10 @@ int main(int argc, char const *const *argv)
     }
   }
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
 
   return 0;
diff --git a/examples/amqps_listenq.c b/examples/amqps_listenq.c
index 1422964..3f6d425 100644
--- a/examples/amqps_listenq.c
+++ b/examples/amqps_listenq.c
@@ -37,8 +37,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -48,8 +48,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *queuename;
@@ -57,7 +56,8 @@ int main(int argc, char const *const *argv)
   amqp_connection_state_t conn;
 
   if (argc < 4) {
-    fprintf(stderr, "Usage: amqps_listenq host port queuename "
+    fprintf(stderr,
+            "Usage: amqps_listenq host port queuename "
             "[cacert.pem [verifypeer] [verifyhostname] [key.pem cert.pem]]\n");
     return 1;
   }
@@ -99,18 +99,19 @@ int main(int argc, char const *const *argv)
     }
   }
 
-
   status = amqp_socket_open(socket, hostname, port);
   if (status) {
     die("opening SSL/TLS connection");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
-  amqp_basic_consume(conn, 1, amqp_cstring_bytes(queuename), amqp_empty_bytes, 0, 0, 0, amqp_empty_table);
+  amqp_basic_consume(conn, 1, amqp_cstring_bytes(queuename), amqp_empty_bytes,
+                     0, 0, 0, amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Consuming");
 
   {
@@ -127,14 +128,14 @@ int main(int argc, char const *const *argv)
       }
 
       printf("Delivery %u, exchange %.*s routingkey %.*s\n",
-             (unsigned) envelope.delivery_tag,
-             (int) envelope.exchange.len, (char *) envelope.exchange.bytes,
-             (int) envelope.routing_key.len, (char *) envelope.routing_key.bytes);
+             (unsigned)envelope.delivery_tag, (int)envelope.exchange.len,
+             (char *)envelope.exchange.bytes, (int)envelope.routing_key.len,
+             (char *)envelope.routing_key.bytes);
 
       if (envelope.message.properties._flags & AMQP_BASIC_CONTENT_TYPE_FLAG) {
         printf("Content-type: %.*s\n",
-               (int) envelope.message.properties.content_type.len,
-               (char *) envelope.message.properties.content_type.bytes);
+               (int)envelope.message.properties.content_type.len,
+               (char *)envelope.message.properties.content_type.bytes);
       }
       printf("----\n");
 
@@ -144,8 +145,10 @@ int main(int argc, char const *const *argv)
     }
   }
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
 
   return 0;
diff --git a/examples/amqps_producer.c b/examples/amqps_producer.c
index 66bd181..120c21b 100644
--- a/examples/amqps_producer.c
+++ b/examples/amqps_producer.c
@@ -37,8 +37,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -48,11 +48,8 @@
 
 #define SUMMARY_EVERY_US 1000000
 
-static void send_batch(amqp_connection_state_t conn,
-                       char const *queue_name,
-                       int rate_limit,
-                       int message_count)
-{
+static void send_batch(amqp_connection_state_t conn, char const *queue_name,
+                       int rate_limit, int message_count) {
   uint64_t start_time = now_microseconds();
   int i;
   int sent = 0;
@@ -73,21 +70,18 @@ static void send_batch(amqp_connection_state_t conn,
   for (i = 0; i < message_count; i++) {
     uint64_t now = now_microseconds();
 
-    die_on_error(amqp_basic_publish(conn,
-                                    1,
-                                    amqp_cstring_bytes("amq.direct"),
-                                    amqp_cstring_bytes(queue_name),
-                                    0,
-                                    0,
-                                    NULL,
+    die_on_error(amqp_basic_publish(conn, 1, amqp_cstring_bytes("amq.direct"),
+                                    amqp_cstring_bytes(queue_name), 0, 0, NULL,
                                     message_bytes),
                  "Publishing");
     sent++;
     if (now > next_summary_time) {
       int countOverInterval = sent - previous_sent;
-      double intervalRate = countOverInterval / ((now - previous_report_time) / 1000000.0);
+      double intervalRate =
+          countOverInterval / ((now - previous_report_time) / 1000000.0);
       printf("%d ms: Sent %d - %d since last report (%d Hz)\n",
-             (int)(now - start_time) / 1000, sent, countOverInterval, (int) intervalRate);
+             (int)(now - start_time) / 1000, sent, countOverInterval,
+             (int)intervalRate);
 
       previous_sent = sent;
       previous_report_time = now;
@@ -106,12 +100,12 @@ static void send_batch(amqp_connection_state_t conn,
 
     printf("PRODUCER - Message count: %d\n", message_count);
     printf("Total time, milliseconds: %d\n", total_delta / 1000);
-    printf("Overall messages-per-second: %g\n", (message_count / (total_delta / 1000000.0)));
+    printf("Overall messages-per-second: %g\n",
+           (message_count / (total_delta / 1000000.0)));
   }
 }
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   int rate_limit;
@@ -120,7 +114,8 @@ int main(int argc, char const *const *argv)
   amqp_connection_state_t conn;
 
   if (argc < 5) {
-    fprintf(stderr, "Usage: amqps_producer host port rate_limit message_count "
+    fprintf(stderr,
+            "Usage: amqps_producer host port rate_limit message_count "
             "[cacert.pem [verifypeer] [verifyhostname] [key.pem cert.pem]]\n");
     return 1;
   }
@@ -168,15 +163,18 @@ int main(int argc, char const *const *argv)
     die("opening SSL/TLS connection");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
   send_batch(conn, "test queue", rate_limit, message_count);
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/amqps_sendstring.c b/examples/amqps_sendstring.c
index 0aebe12..9fed198 100644
--- a/examples/amqps_sendstring.c
+++ b/examples/amqps_sendstring.c
@@ -37,8 +37,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -46,8 +46,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -57,7 +56,8 @@ int main(int argc, char const *const *argv)
   amqp_connection_state_t conn;
 
   if (argc < 6) {
-    fprintf(stderr, "Usage: amqps_sendstring host port exchange routingkey "
+    fprintf(stderr,
+            "Usage: amqps_sendstring host port exchange routingkey "
             "messagebody [cacert.pem [verifypeer] [verifyhostname] "
             "[key.pem cert.pem]]\n");
     return 1;
@@ -107,7 +107,8 @@ int main(int argc, char const *const *argv)
     die("opening SSL/TLS connection");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
@@ -117,19 +118,16 @@ int main(int argc, char const *const *argv)
     props._flags = AMQP_BASIC_CONTENT_TYPE_FLAG | AMQP_BASIC_DELIVERY_MODE_FLAG;
     props.content_type = amqp_cstring_bytes("text/plain");
     props.delivery_mode = 2; /* persistent delivery mode */
-    die_on_error(amqp_basic_publish(conn,
-                                    1,
-                                    amqp_cstring_bytes(exchange),
-                                    amqp_cstring_bytes(routingkey),
-                                    0,
-                                    0,
-                                    &props,
-                                    amqp_cstring_bytes(messagebody)),
+    die_on_error(amqp_basic_publish(conn, 1, amqp_cstring_bytes(exchange),
+                                    amqp_cstring_bytes(routingkey), 0, 0,
+                                    &props, amqp_cstring_bytes(messagebody)),
                  "Publishing");
   }
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/amqps_unbind.c b/examples/amqps_unbind.c
index e10f514..aad45c5 100644
--- a/examples/amqps_unbind.c
+++ b/examples/amqps_unbind.c
@@ -37,8 +37,8 @@
  */
 
 #include <stdint.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
 
 #include <amqp.h>
@@ -46,8 +46,7 @@
 
 #include "utils.h"
 
-int main(int argc, char const *const *argv)
-{
+int main(int argc, char const *const *argv) {
   char const *hostname;
   int port, status;
   char const *exchange;
@@ -57,7 +56,8 @@ int main(int argc, char const *const *argv)
   amqp_connection_state_t conn;
 
   if (argc < 6) {
-    fprintf(stderr, "Usage: amqps_unbind host port exchange bindingkey queue "
+    fprintf(stderr,
+            "Usage: amqps_unbind host port exchange bindingkey queue "
             "[cacert.pem [verifypeer] [verifyhostname] [key.pem cert.pem]]\n");
     return 1;
   }
@@ -106,20 +106,21 @@ int main(int argc, char const *const *argv)
     die("opening SSL/TLS connection");
   }
 
-  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
+  die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN,
+                               "guest", "guest"),
                     "Logging in");
   amqp_channel_open(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
 
-  amqp_queue_unbind(conn, 1,
-                    amqp_cstring_bytes(queue),
+  amqp_queue_unbind(conn, 1, amqp_cstring_bytes(queue),
                     amqp_cstring_bytes(exchange),
-                    amqp_cstring_bytes(bindingkey),
-                    amqp_empty_table);
+                    amqp_cstring_bytes(bindingkey), amqp_empty_table);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Unbinding");
 
-  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
-  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
+  die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
+                    "Closing channel");
+  die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS),
+                    "Closing connection");
   die_on_error(amqp_destroy_connection(conn), "Ending connection");
   return 0;
 }
diff --git a/examples/unix/platform_utils.c b/examples/unix/platform_utils.c
index 06ca53f..e420b82 100644
--- a/examples/unix/platform_utils.c
+++ b/examples/unix/platform_utils.c
@@ -34,19 +34,17 @@
  */
 
 #include <stdint.h>
-#include <time.h>
 #include <sys/time.h>
+#include <time.h>
 #include <unistd.h>
 
-uint64_t now_microseconds(void)
-{
+uint64_t now_microseconds(void) {
   struct timeval tv;
   gettimeofday(&tv, NULL);
-  return (uint64_t) tv.tv_sec * 1000000 + (uint64_t) tv.tv_usec;
+  return (uint64_t)tv.tv_sec * 1000000 + (uint64_t)tv.tv_usec;
 }
 
-void microsleep(int usec)
-{
+void microsleep(int usec) {
   struct timespec req;
   req.tv_sec = 0;
   req.tv_nsec = 1000 * usec;
diff --git a/examples/utils.c b/examples/utils.c
index 3e0cad9..8d1b4c6 100644
--- a/examples/utils.c
+++ b/examples/utils.c
@@ -33,20 +33,19 @@
  * ***** END LICENSE BLOCK *****
  */
 
+#include <ctype.h>
 #include <stdarg.h>
-#include <stdlib.h>
 #include <stdio.h>
+#include <stdlib.h>
 #include <string.h>
-#include <ctype.h>
 
-#include <stdint.h>
 #include <amqp.h>
 #include <amqp_framing.h>
+#include <stdint.h>
 
 #include "utils.h"
 
-void die(const char *fmt, ...)
-{
+void die(const char *fmt, ...) {
   va_list ap;
   va_start(ap, fmt);
   vfprintf(stderr, fmt, ap);
@@ -55,58 +54,55 @@ void die(const char *fmt, ...)
   exit(1);
 }
 
-void die_on_error(int x, char const *context)
-{
+void die_on_error(int x, char const *context) {
   if (x < 0) {
     fprintf(stderr, "%s: %s\n", context, amqp_error_string2(x));
     exit(1);
   }
 }
 
-void die_on_amqp_error(amqp_rpc_reply_t x, char const *context)
-{
+void die_on_amqp_error(amqp_rpc_reply_t x, char const *context) {
   switch (x.reply_type) {
-  case AMQP_RESPONSE_NORMAL:
-    return;
-
-  case AMQP_RESPONSE_NONE:
-    fprintf(stderr, "%s: missing RPC reply type!\n", context);
-    break;
-
-  case AMQP_RESPONSE_LIBRARY_EXCEPTION:
-    fprintf(stderr, "%s: %s\n", context, amqp_error_string2(x.library_error));
-    break;
-
-  case AMQP_RESPONSE_SERVER_EXCEPTION:
-    switch (x.reply.id) {
-    case AMQP_CONNECTION_CLOSE_METHOD: {
-      amqp_connection_close_t *m = (amqp_connection_close_t *) x.reply.decoded;
-      fprintf(stderr, "%s: server connection error %uh, message: %.*s\n",
-              context,
-              m->reply_code,
-              (int) m->reply_text.len, (char *) m->reply_text.bytes);
+    case AMQP_RESPONSE_NORMAL:
+      return;
+
+    case AMQP_RESPONSE_NONE:
+      fprintf(stderr, "%s: missing RPC reply type!\n", context);
       break;
-    }
-    case AMQP_CHANNEL_CLOSE_METHOD: {
-      amqp_channel_close_t *m = (amqp_channel_close_t *) x.reply.decoded;
-      fprintf(stderr, "%s: server channel error %uh, message: %.*s\n",
-              context,
-              m->reply_code,
-              (int) m->reply_text.len, (char *) m->reply_text.bytes);
+
+    case AMQP_RESPONSE_LIBRARY_EXCEPTION:
+      fprintf(stderr, "%s: %s\n", context, amqp_error_string2(x.library_error));
       break;
-    }
-    default:
-      fprintf(stderr, "%s: unknown server error, method id 0x%08X\n", context, x.reply.id);
+
+    case AMQP_RESPONSE_SERVER_EXCEPTION:
+      switch (x.reply.id) {
+        case AMQP_CONNECTION_CLOSE_METHOD: {
+          amqp_connection_close_t *m =
+              (amqp_connection_close_t *)x.reply.decoded;
+          fprintf(stderr, "%s: server connection error %uh, message: %.*s\n",
+                  context, m->reply_code, (int)m->reply_text.len,
+                  (char *)m->reply_text.bytes);
+          break;
+        }
+        case AMQP_CHANNEL_CLOSE_METHOD: {
+          amqp_channel_close_t *m = (amqp_channel_close_t *)x.reply.decoded;
+          fprintf(stderr, "%s: server channel error %uh, message: %.*s\n",
+                  context, m->reply_code, (int)m->reply_text.len,
+                  (char *)m->reply_text.bytes);
+          break;
+        }
+        default:
+          fprintf(stderr, "%s: unknown server error, method id 0x%08X\n",
+                  context, x.reply.id);
+          break;
+      }
       break;
-    }
-    break;
   }
 
   exit(1);
 }
 
-static void dump_row(long count, int numinrow, int *chs)
-{
+static void dump_row(long count, int numinrow, int *chs) {
   int i;
 
   printf("%08lX:", count - numinrow);
@@ -136,11 +132,10 @@ static void dump_row(long count, int numinrow, int *chs)
   printf("\n");
 }
 
-static int rows_eq(int *a, int *b)
-{
+static int rows_eq(int *a, int *b) {
   int i;
 
-  for (i=0; i<16; i++)
+  for (i = 0; i < 16; i++)
     if (a[i] != b[i]) {
       return 0;
     }
@@ -148,9 +143,8 @@ static int rows_eq(int *a, int *b)
   return 1;
 }
 
-void amqp_dump(void const *buffer, size_t len)
-{
-  unsigned char *buf = (unsigned char *) buffer;
+void amqp_dump(void const *buffer, size_t len) {
+  unsigned char *buf = (unsigned char *)buffer;
   long count = 0;
   int numinrow = 0;
   int chs[16];
@@ -167,14 +161,15 @@ void amqp_dump(void const *buffer, size_t len)
       if (rows_eq(oldchs, chs)) {
         if (!showed_dots) {
           showed_dots = 1;
-          printf("          .. .. .. .. .. .. .. .. : .. .. .. .. .. .. .. ..\n");
+          printf(
+              "          .. .. .. .. .. .. .. .. : .. .. .. .. .. .. .. ..\n");
         }
       } else {
         showed_dots = 0;
         dump_row(count, numinrow, chs);
       }
 
-      for (j=0; j<16; j++) {
+      for (j = 0; j < 16; j++) {
         oldchs[j] = chs[j];
       }
 
diff --git a/examples/win32/platform_utils.c b/examples/win32/platform_utils.c
index b75c996..49fd377 100644
--- a/examples/win32/platform_utils.c
+++ b/examples/win32/platform_utils.c
@@ -37,15 +37,11 @@
 
 #include <windows.h>
 
-uint64_t now_microseconds(void)
-{
+uint64_t now_microseconds(void) {
   FILETIME ft;
   GetSystemTimeAsFileTime(&ft);
-  return (((uint64_t)ft.dwHighDateTime << 32) | (uint64_t)ft.dwLowDateTime)
-         / 10;
+  return (((uint64_t)ft.dwHighDateTime << 32) | (uint64_t)ft.dwLowDateTime) /
+         10;
 }
 
-void microsleep(int usec)
-{
-  Sleep(usec / 1000);
-}
+void microsleep(int usec) { Sleep(usec / 1000); }