summaryrefslogtreecommitdiff
path: root/librabbitmq/amqp_socket.c
diff options
context:
space:
mode:
Diffstat (limited to 'librabbitmq/amqp_socket.c')
-rw-r--r--librabbitmq/amqp_socket.c18
1 files changed, 14 insertions, 4 deletions
diff --git a/librabbitmq/amqp_socket.c b/librabbitmq/amqp_socket.c
index ecb7de5..f0f8b9f 100644
--- a/librabbitmq/amqp_socket.c
+++ b/librabbitmq/amqp_socket.c
@@ -697,11 +697,16 @@ amqp_rpc_reply_t amqp_login(amqp_connection_state_t state,
...)
{
va_list vl;
+ amqp_rpc_reply_t ret;
va_start(vl, sasl_method);
- return amqp_login_inner(state, vhost, channel_max, frame_max, heartbeat,
- &amqp_empty_table, sasl_method, vl);
+ ret = amqp_login_inner(state, vhost, channel_max, frame_max, heartbeat,
+ &amqp_empty_table, sasl_method, vl);
+
+ va_end(vl);
+
+ return ret;
}
amqp_rpc_reply_t amqp_login_with_properties(amqp_connection_state_t state,
@@ -714,9 +719,14 @@ amqp_rpc_reply_t amqp_login_with_properties(amqp_connection_state_t state,
...)
{
va_list vl;
+ amqp_rpc_reply_t ret;
va_start(vl, sasl_method);
- return amqp_login_inner(state, vhost, channel_max, frame_max, heartbeat,
- client_properties, sasl_method, vl);
+ ret = amqp_login_inner(state, vhost, channel_max, frame_max, heartbeat,
+ client_properties, sasl_method, vl);
+
+ va_end(vl);
+
+ return ret;
}