[sr-dev] git:master:88ebe33b: rabbitmq: call function to release the amqp buffers

Module: kamailio Branch: master Commit: 88ebe33b6f8a21df6fa0720fef62dabe6b089c87 URL: https://github.com/kamailio/kamailio/commit/88ebe33b6f8a21df6fa0720fef62dab… Author: Daniel-Constantin Mierla <miconda(a)gmail.com> Committer: Daniel-Constantin Mierla <miconda(a)gmail.com> Date: 2018-11-05T10:20:02+01:00 rabbitmq: call function to release the amqp buffers --- Modified: src/modules/rabbitmq/rabbitmq.c --- Diff: https://github.com/kamailio/kamailio/commit/88ebe33b6f8a21df6fa0720fef62dab… Patch: https://github.com/kamailio/kamailio/commit/88ebe33b6f8a21df6fa0720fef62dab… --- diff --git a/src/modules/rabbitmq/rabbitmq.c b/src/modules/rabbitmq/rabbitmq.c index a5982608d3..373b5dd036 100644 --- a/src/modules/rabbitmq/rabbitmq.c +++ b/src/modules/rabbitmq/rabbitmq.c @@ -238,6 +238,7 @@ static int ki_rabbitmq_publish(sip_msg_t *msg, str *exchange, str *routingkey, LM_ERR("FAIL: amqp_basic_publish()\n"); // cleanup + amqp_maybe_release_buffers(amqp_conn); amqp_channel_close(amqp_conn, 1, AMQP_REPLY_SUCCESS); // error @@ -248,6 +249,7 @@ static int ki_rabbitmq_publish(sip_msg_t *msg, str *exchange, str *routingkey, LM_DBG("SUCCESS: amqp_basic_publish()\n"); // cleanup + amqp_maybe_release_buffers(amqp_conn); amqp_channel_close(amqp_conn, 1, AMQP_REPLY_SUCCESS); // success