diff options
author | Tony Garnock-Jones <tonyg@lshift.net> | 2009-05-07 13:26:13 +0100 |
---|---|---|
committer | Tony Garnock-Jones <tonyg@lshift.net> | 2009-05-07 13:26:13 +0100 |
commit | 93cad29ef824581c7e6facbfb1eb62600f9dd93d (patch) | |
tree | 674b38c0f127e340857ef3a7ecb595bcafe1211f | |
parent | a0a9c9d617b74e59be24531902f083e5b815a360 (diff) | |
download | rabbitmq-c-github-ask-93cad29ef824581c7e6facbfb1eb62600f9dd93d.tar.gz |
Send non-empty strings in .close messages
-rw-r--r-- | librabbitmq/amqp_api.c | 8 |
1 files 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; |