Diff: message_sender.c

Revision:

31:cafc87baef79

Parent:

29:4a11413cf217

Child:

33:08b53020ff0d

diff -r 0407b2db334c -r cafc87baef79 message_sender.c
--- a/message_sender.c	Fri Jul 28 09:52:29 2017 -0700
+++ b/message_sender.c	Fri Aug 11 14:02:44 2017 -0700
@@ -184,12 +184,12 @@
     else
     {
         // header
-        HEADER_HANDLE header;
-        AMQP_VALUE header_amqp_value;
-        PROPERTIES_HANDLE properties;
-        AMQP_VALUE properties_amqp_value;
-        AMQP_VALUE application_properties;
-        AMQP_VALUE application_properties_value;
+        HEADER_HANDLE header = NULL;
+        AMQP_VALUE header_amqp_value = NULL;
+        PROPERTIES_HANDLE properties = NULL;
+        AMQP_VALUE properties_amqp_value = NULL;
+        AMQP_VALUE application_properties = NULL;
+        AMQP_VALUE application_properties_value = NULL;
         AMQP_VALUE body_amqp_value = NULL;
         size_t body_data_count = 0;
         AMQP_VALUE msg_annotations = NULL;
@@ -447,6 +447,21 @@
             }
         }
 
+        if (header != NULL)
+        {
+            header_destroy(header);
+        }
+
+        if (header_amqp_value != NULL)
+        {
+            amqpvalue_destroy(header_amqp_value);
+        }
+
+        if (msg_annotations != NULL)
+        {
+            annotations_destroy(msg_annotations);
+        }
+
         if (application_properties != NULL)
         {
             amqpvalue_destroy(application_properties);