From 93cad29ef824581c7e6facbfb1eb62600f9dd93d Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Thu, 7 May 2009 13:26:13 +0100 Subject: Send non-empty strings in .close messages --- librabbitmq/amqp_api.c | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/librabbitmq/amqp_api.c b/librabbitmq/amqp_api.c index 064436f..b6dc647 100644 --- a/librabbitmq/amqp_api.c +++ b/librabbitmq/amqp_api.c @@ -71,15 +71,19 @@ int amqp_basic_publish(amqp_connection_state_t state, } amqp_rpc_reply_t amqp_channel_close(amqp_connection_state_t state, int code) { + char codestr[13]; + snprintf(codestr, sizeof(codestr), "%d", code); return AMQP_SIMPLE_RPC(state, 1, CHANNEL, CLOSE, CLOSE_OK, amqp_channel_close_t, - code, {0,NULL}, 0, 0); + code, amqp_cstring_bytes(codestr), 0, 0); } amqp_rpc_reply_t amqp_connection_close(amqp_connection_state_t state, int code) { + char codestr[13]; + snprintf(codestr, sizeof(codestr), "%d", code); return AMQP_SIMPLE_RPC(state, 0, CONNECTION, CLOSE, CLOSE_OK, amqp_connection_close_t, - code, {0,NULL}, 0, 0); + code, amqp_cstring_bytes(codestr), 0, 0); } amqp_rpc_reply_t amqp_rpc_reply; -- cgit v1.2.1