Cosmetic update

rmqplus.c

@@ -127,5 +127,5 @@
 /*
     send the message
 */
-amqp_send_message(const char *messagebody) {
+int amqp_send_message(const char *messagebody) {
     int s;
@@ -131,4 +131,11 @@
     int s;
+    int result;
+
+    amqp_basic_deliver_t *d;
+    amqp_basic_properties_t *p;
+    size_t body_target;
+    size_t body_received;
+
     /*
       set properties
     */
@@ -160,9 +167,8 @@
     wait an answer
   */
 
-  {
     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);
 
@@ -164,16 +170,8 @@
     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);
 
-    {
-      int result;
-
-      amqp_basic_deliver_t *d;
-      amqp_basic_properties_t *p;
-      size_t body_target;
-      size_t body_received;
-
     for (;;) {
         amqp_maybe_release_buffers(conn);
         result = amqp_simple_wait_frame(conn, &frame);
@@ -234,8 +232,6 @@
         /* everything was fine, we can quit now because we received the reply */
         break;
     }
-    }
-  }
     return 1;
 }