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

Daniel-Constantin Mierla miconda at gmail.com
Mon Nov 5 10:21:19 CET 2018


Module: kamailio
Branch: master
Commit: 88ebe33b6f8a21df6fa0720fef62dabe6b089c87
URL: https://github.com/kamailio/kamailio/commit/88ebe33b6f8a21df6fa0720fef62dabe6b089c87

Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Daniel-Constantin Mierla <miconda at 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/88ebe33b6f8a21df6fa0720fef62dabe6b089c87.diff
Patch: https://github.com/kamailio/kamailio/commit/88ebe33b6f8a21df6fa0720fef62dabe6b089c87.patch

---

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




More information about the sr-dev mailing list