A small memory footprint AMQP implimentation
Dependents: iothub_client_sample_amqp remote_monitoring simplesample_amqp
Diff: message_sender.c
- Revision:
- 24:2c59c2d43ebf
- Parent:
- 23:1111ee8bcba4
- Child:
- 25:1101516ee67d
diff -r 1111ee8bcba4 -r 2c59c2d43ebf message_sender.c --- a/message_sender.c Fri Apr 21 14:50:32 2017 -0700 +++ b/message_sender.c Mon May 08 10:50:45 2017 -0700 @@ -243,7 +243,7 @@ case MESSAGE_BODY_TYPE_VALUE: { AMQP_VALUE message_body_amqp_value; - if (message_get_inplace_body_amqp_value(message, &message_body_amqp_value) != 0) + if (message_get_body_amqp_value_in_place(message, &message_body_amqp_value) != 0) { result = SEND_ONE_MESSAGE_ERROR; } @@ -277,7 +277,7 @@ { for (i = 0; i < body_data_count; i++) { - if (message_get_body_amqp_data(message, i, &binary_data) != 0) + if (message_get_body_amqp_data_in_place(message, i, &binary_data) != 0) { result = SEND_ONE_MESSAGE_ERROR; } @@ -384,7 +384,7 @@ for (i = 0; i < body_data_count; i++) { - if (message_get_body_amqp_data(message, i, &binary_data) != 0) + if (message_get_body_amqp_data_in_place(message, i, &binary_data) != 0) { result = SEND_ONE_MESSAGE_ERROR; }