A small memory footprint AMQP implimentation
Dependents: iothub_client_sample_amqp remote_monitoring simplesample_amqp
Diff: amqp_management.c
- Revision:
- 34:6be9c2058664
- Parent:
- 28:add19eb7defa
- Child:
- 35:d0bed2404ee9
diff -r 08b53020ff0d -r 6be9c2058664 amqp_management.c --- 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);