diff options
| author | Alan Antonuk <alan.antonuk@gmail.com> | 2014-12-25 21:51:49 -0800 |
|---|---|---|
| committer | Alan Antonuk <alan.antonuk@gmail.com> | 2015-05-06 23:52:26 -0700 |
| commit | c46366f11e2cc14c501073a1f909aef0c2c2e949 (patch) | |
| tree | f5c70668157445ab49ab95d6937a1ca8a84d4ed7 | |
| parent | fb8e31833ffc92ba3ce8d5b7e5913ba07925b887 (diff) | |
| download | rabbitmq-c-c46366f11e2cc14c501073a1f909aef0c2c2e949.tar.gz | |
Add auth failure client capability as default.
| -rw-r--r-- | librabbitmq/amqp_socket.c | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c index d234c0d..bb90477 100644 --- a/librabbitmq/amqp_socket.c +++ b/librabbitmq/amqp_socket.c @@ -1211,8 +1211,10 @@ static amqp_rpc_reply_t amqp_login_inner(amqp_connection_state_t state, } { - amqp_table_entry_t default_properties[5]; + amqp_table_entry_t default_properties[6]; amqp_table_t default_table; + amqp_table_entry_t client_capabilities[1]; + amqp_table_t client_capabilities_table; amqp_connection_start_ok_t s; amqp_pool_t *channel_pool; amqp_bytes_t response_bytes; @@ -1230,7 +1232,12 @@ static amqp_rpc_reply_t amqp_login_inner(amqp_connection_state_t state, goto error_res; } + client_capabilities[0] = + amqp_table_construct_bool_entry("authentication_failure_close", 1); + client_capabilities_table.entries = client_capabilities; + client_capabilities_table.num_entries = + sizeof(client_capabilities) / sizeof(amqp_table_entry_t); default_properties[0] = amqp_table_construct_utf8_entry("product", "rabbitmq-c"); @@ -1242,6 +1249,8 @@ static amqp_rpc_reply_t amqp_login_inner(amqp_connection_state_t state, amqp_table_construct_utf8_entry("copyright", AMQ_COPYRIGHT); default_properties[4] = amqp_table_construct_utf8_entry( "information", "See https://github.com/alanxz/rabbitmq-c"); + default_properties[5] = amqp_table_construct_table_entry( + "capabilities", &client_capabilities_table); default_table.entries = default_properties; default_table.num_entries = |