examples: show that you can pass amqp_bytes_t as function argument (#867)

* examples: show that you can pass amqp_bytes_t as function argument

Author: vfjpl

examples/amqp_confirm_select.c

@@ -26,7 +26,7 @@
 
 #define SUMMARY_EVERY_US 5000
 
-static void send_batch(amqp_connection_state_t conn, char const *queue_name,
+static void send_batch(amqp_connection_state_t conn, amqp_bytes_t queue_name,
                        int rate_limit, int message_count) {
   uint64_t start_time = now_microseconds();
   int i;
@@ -49,8 +49,7 @@ static void send_batch(amqp_connection_state_t conn, char const *queue_name,
     uint64_t now = now_microseconds();
 
     die_on_error(amqp_basic_publish(conn, 1, amqp_literal_bytes("amq.direct"),
-                                    amqp_cstring_bytes(queue_name), 0, 0, NULL,
-                                    message_bytes),
+                                    queue_name, 0, 0, NULL, message_bytes),
                  "Publishing");
     sent++;
     if (now > next_summary_time) {
@@ -177,7 +176,7 @@ int main(int argc, char const *const *argv) {
   amqp_confirm_select(conn, 1);
   die_on_amqp_error(amqp_get_rpc_reply(conn), "Enable confirm-select");
 
-  send_batch(conn, "test queue", rate_limit, message_count);
+  send_batch(conn, amqp_literal_bytes("test queue"), rate_limit, message_count);
 
   wait_for_acks(conn);
   die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),

examples/amqp_producer.c

@@ -13,7 +13,7 @@
 
 #define SUMMARY_EVERY_US 1000000
 
-static void send_batch(amqp_connection_state_t conn, char const *queue_name,
+static void send_batch(amqp_connection_state_t conn, amqp_bytes_t queue_name,
                        int rate_limit, int message_count) {
   uint64_t start_time = now_microseconds();
   int i;
@@ -36,8 +36,7 @@ static void send_batch(amqp_connection_state_t conn, char const *queue_name,
     uint64_t now = now_microseconds();
 
     die_on_error(amqp_basic_publish(conn, 1, amqp_literal_bytes("amq.direct"),
-                                    amqp_cstring_bytes(queue_name), 0, 0, NULL,
-                                    message_bytes),
+                                    queue_name, 0, 0, NULL, message_bytes),
                  "Publishing");
     sent++;
     if (now > next_summary_time) {
@@ -107,7 +106,7 @@ int main(int argc, char const *const *argv) {
   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);
+  send_batch(conn, amqp_literal_bytes("test queue"), rate_limit, message_count);
 
   die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS),
                     "Closing channel");