summaryrefslogtreecommitdiff
path: root/examples/amqps_exchange_declare.c
diff options
context:
space:
mode:
Diffstat (limited to 'examples/amqps_exchange_declare.c')
-rw-r--r--examples/amqps_exchange_declare.c9
1 files changed, 5 insertions, 4 deletions
diff --git a/examples/amqps_exchange_declare.c b/examples/amqps_exchange_declare.c
index c9f2e6c..199c0c5 100644
--- a/examples/amqps_exchange_declare.c
+++ b/examples/amqps_exchange_declare.c
@@ -41,7 +41,8 @@
#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;
@@ -51,7 +52,7 @@ int main(int argc, char const * const *argv) {
if (argc < 5) {
fprintf(stderr, "Usage: amqps_exchange_declare host port exchange "
- "exchangetype [cacert.pem [key.pem cert.pem]]\n");
+ "exchangetype [cacert.pem [key.pem cert.pem]]\n");
return 1;
}
@@ -88,12 +89,12 @@ int main(int argc, char const * const *argv) {
amqp_set_socket(conn, socket);
die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
- "Logging in");
+ "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, amqp_empty_table);
+ 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");