summaryrefslogtreecommitdiff
path: root/librabbitmq/amqp_connection.c
diff options
context:
space:
mode:
authorAlan Antonuk <alan.antonuk@gmail.com>2013-08-15 13:40:44 -0700
committerAlan Antonuk <alan.antonuk@gmail.com>2013-08-15 13:40:44 -0700
commit1c213703c9fdd747bc71ea4f64943c3b4269f8cf (patch)
tree363403985fdb0125497016227308e1db4f1e0a63 /librabbitmq/amqp_connection.c
parent5c7c40adc100c3a29ec9df5959e2124abcfed487 (diff)
downloadrabbitmq-c-github-ask-1c213703c9fdd747bc71ea4f64943c3b4269f8cf.tar.gz
Add amqp_get_broker_properties() function
Add function to return the properties table advertised by the broker on connection to the broker.
Diffstat (limited to 'librabbitmq/amqp_connection.c')
-rw-r--r--librabbitmq/amqp_connection.c3
1 files changed, 3 insertions, 0 deletions
diff --git a/librabbitmq/amqp_connection.c b/librabbitmq/amqp_connection.c
index df6a462..d3491fb 100644
--- a/librabbitmq/amqp_connection.c
+++ b/librabbitmq/amqp_connection.c
@@ -91,6 +91,8 @@ amqp_connection_state_t amqp_new_connection(void)
goto out_nomem;
}
+ init_amqp_pool(&state->properties_pool, 512);
+
return state;
out_nomem:
@@ -181,6 +183,7 @@ int amqp_destroy_connection(amqp_connection_state_t state)
free(state->outbound_buffer.bytes);
free(state->sock_inbound_buffer.bytes);
amqp_socket_delete(state->socket);
+ empty_amqp_pool(&state->properties_pool);
free(state);
}
return status;