Diff: amqp_management.c

Revision:

34:6be9c2058664

Parent:

28:add19eb7defa

Child:

35:d0bed2404ee9

--- a/amqp_management.c	Mon Sep 25 13:38:40 2017 -0700
+++ b/amqp_management.c	Sat Oct 21 20:12:19 2017 +0000
@@ -1071,9 +1071,9 @@
                                 else
                                 {
                                     /* Codes_SRS_AMQP_MANAGEMENT_01_088: [ `amqp_management_execute_operation_async` shall send the message by calling `messagesender_send`. ]*/
-                                    if (messagesender_send(amqp_management->message_sender, cloned_message, NULL, NULL) != 0)
+                                    if (messagesender_send_async(amqp_management->message_sender, cloned_message, NULL, NULL, 0) == NULL)
                                     {
-                                        /* Codes_SRS_AMQP_MANAGEMENT_01_089: [ If `messagesender_send` fails, `amqp_management_execute_operation_async` shall fail and return a non-zero value. ]*/
+                                        /* Codes_SRS_AMQP_MANAGEMENT_01_089: [ If `messagesender_send_async` fails, `amqp_management_execute_operation_async` shall fail and return a non-zero value. ]*/
                                         LogError("Could not send request message");
                                         (void)singlylinkedlist_remove(amqp_management->pending_operations, added_item);
                                         free(pending_operation_message);