Azure IoT / Mbed 2 deprecated iothub_client_sample_amqp

IoTHub raw messaging client sample using AMQP

Dependencies:   iothub_client EthernetInterface NTPClient iothub_amqp_transport azure_c_shared_utility mbed-rtos mbed azure_uamqp_c wolfSSL

This sample showcases the usage of Azure IoT client libraries with the AMQP transport for sending/receiving raw messages from an IoT Hub.

iothub_client_sample_amqp.c@0:eb1c7bc1f4f1, 2015-09-15 (annotated)

Committer:
AzureIoTClient
Date:
Tue Sep 15 22:44:58 2015 -0700
Revision:
0:eb1c7bc1f4f1
Child:
4:24cbfabe1b9d
New release

Who changed what in which revision?

UserRevisionLine numberNew contents of line
AzureIoTClient 0:eb1c7bc1f4f1 1 // Copyright (c) Microsoft. All rights reserved.
AzureIoTClient 0:eb1c7bc1f4f1 2 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
AzureIoTClient 0:eb1c7bc1f4f1 3
AzureIoTClient 0:eb1c7bc1f4f1 4 #include <stdio.h>
AzureIoTClient 0:eb1c7bc1f4f1 5
AzureIoTClient 0:eb1c7bc1f4f1 6 #include "iothub_client.h"
AzureIoTClient 0:eb1c7bc1f4f1 7 #include "iothub_message.h"
AzureIoTClient 0:eb1c7bc1f4f1 8 #include "threadapi.h"
AzureIoTClient 0:eb1c7bc1f4f1 9 #include "crt_abstractions.h"
AzureIoTClient 0:eb1c7bc1f4f1 10 #include "iothubtransportamqp.h"
AzureIoTClient 0:eb1c7bc1f4f1 11
AzureIoTClient 0:eb1c7bc1f4f1 12 #ifdef MBED_BUILD_TIMESTAMP
AzureIoTClient 0:eb1c7bc1f4f1 13 #include "certs.h"
AzureIoTClient 0:eb1c7bc1f4f1 14 #endif // MBED_BUILD_TIMESTAMP
AzureIoTClient 0:eb1c7bc1f4f1 15
AzureIoTClient 0:eb1c7bc1f4f1 16 static const char* connectionString = "[device connection string]";
AzureIoTClient 0:eb1c7bc1f4f1 17 static int callbackCounter;
AzureIoTClient 0:eb1c7bc1f4f1 18
AzureIoTClient 0:eb1c7bc1f4f1 19 DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_CONFIRMATION_RESULT, IOTHUB_CLIENT_CONFIRMATION_RESULT_VALUES);
AzureIoTClient 0:eb1c7bc1f4f1 20
AzureIoTClient 0:eb1c7bc1f4f1 21 typedef struct EVENT_INSTANCE_TAG
AzureIoTClient 0:eb1c7bc1f4f1 22 {
AzureIoTClient 0:eb1c7bc1f4f1 23 IOTHUB_MESSAGE_HANDLE messageHandle;
AzureIoTClient 0:eb1c7bc1f4f1 24 int messageTrackingId; // For tracking the messages within the user callback.
AzureIoTClient 0:eb1c7bc1f4f1 25 } EVENT_INSTANCE;
AzureIoTClient 0:eb1c7bc1f4f1 26
AzureIoTClient 0:eb1c7bc1f4f1 27 static IOTHUBMESSAGE_DISPOSITION_RESULT ReceiveNotificationCallback(IOTHUB_MESSAGE_HANDLE notificationMessage, void* userContextCallback)
AzureIoTClient 0:eb1c7bc1f4f1 28 {
AzureIoTClient 0:eb1c7bc1f4f1 29 int* counter = (int*)userContextCallback;
AzureIoTClient 0:eb1c7bc1f4f1 30 const char* buffer;
AzureIoTClient 0:eb1c7bc1f4f1 31 size_t size;
AzureIoTClient 0:eb1c7bc1f4f1 32 if (IoTHubMessage_GetByteArray(notificationMessage, (const unsigned char**)&buffer, &size) == IOTHUB_MESSAGE_OK)
AzureIoTClient 0:eb1c7bc1f4f1 33 {
AzureIoTClient 0:eb1c7bc1f4f1 34 (void)printf("Received Notification [%d] with Data: <<<%.*s>>> & Size=%d\r\n", *counter, (int)size, buffer, (int)size);
AzureIoTClient 0:eb1c7bc1f4f1 35 }
AzureIoTClient 0:eb1c7bc1f4f1 36
AzureIoTClient 0:eb1c7bc1f4f1 37 // Retrieve properties from the message
AzureIoTClient 0:eb1c7bc1f4f1 38 MAP_HANDLE mapProperties = IoTHubMessage_Properties(notificationMessage);
AzureIoTClient 0:eb1c7bc1f4f1 39 if (mapProperties != NULL)
AzureIoTClient 0:eb1c7bc1f4f1 40 {
AzureIoTClient 0:eb1c7bc1f4f1 41 const char*const* keys;
AzureIoTClient 0:eb1c7bc1f4f1 42 const char*const* values;
AzureIoTClient 0:eb1c7bc1f4f1 43 size_t propertyCount = 0;
AzureIoTClient 0:eb1c7bc1f4f1 44 if (Map_GetInternals(mapProperties, &keys, &values, &propertyCount) == MAP_OK)
AzureIoTClient 0:eb1c7bc1f4f1 45 {
AzureIoTClient 0:eb1c7bc1f4f1 46 if (propertyCount > 0)
AzureIoTClient 0:eb1c7bc1f4f1 47 {
AzureIoTClient 0:eb1c7bc1f4f1 48 printf("Message Properties:\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 49 for (size_t index = 0; index < propertyCount; index++)
AzureIoTClient 0:eb1c7bc1f4f1 50 {
AzureIoTClient 0:eb1c7bc1f4f1 51 printf("\tKey: %s Value: %s\r\n", keys[index], values[index]);
AzureIoTClient 0:eb1c7bc1f4f1 52 }
AzureIoTClient 0:eb1c7bc1f4f1 53 printf("\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 54 }
AzureIoTClient 0:eb1c7bc1f4f1 55 }
AzureIoTClient 0:eb1c7bc1f4f1 56 }
AzureIoTClient 0:eb1c7bc1f4f1 57
AzureIoTClient 0:eb1c7bc1f4f1 58 /* Some device specific action code goes here... */
AzureIoTClient 0:eb1c7bc1f4f1 59 (*counter)++;
AzureIoTClient 0:eb1c7bc1f4f1 60 return IOTHUBMESSAGE_ACCEPTED;
AzureIoTClient 0:eb1c7bc1f4f1 61 }
AzureIoTClient 0:eb1c7bc1f4f1 62
AzureIoTClient 0:eb1c7bc1f4f1 63 static void SendConfirmationCallback(IOTHUB_CLIENT_CONFIRMATION_RESULT result, void* userContextCallback)
AzureIoTClient 0:eb1c7bc1f4f1 64 {
AzureIoTClient 0:eb1c7bc1f4f1 65 EVENT_INSTANCE* eventInstance = (EVENT_INSTANCE*)userContextCallback;
AzureIoTClient 0:eb1c7bc1f4f1 66 (void)printf("Confirmation[%d] received for message tracking id = %d with result = %s\r\n", callbackCounter, eventInstance->messageTrackingId, ENUM_TO_STRING(IOTHUB_CLIENT_CONFIRMATION_RESULT, result));
AzureIoTClient 0:eb1c7bc1f4f1 67 /* Some device specific action code goes here... */
AzureIoTClient 0:eb1c7bc1f4f1 68 callbackCounter++;
AzureIoTClient 0:eb1c7bc1f4f1 69 IoTHubMessage_Destroy(eventInstance->messageHandle);
AzureIoTClient 0:eb1c7bc1f4f1 70 }
AzureIoTClient 0:eb1c7bc1f4f1 71
AzureIoTClient 0:eb1c7bc1f4f1 72 static char msgText[1024];
AzureIoTClient 0:eb1c7bc1f4f1 73 static char propText[1024];
AzureIoTClient 0:eb1c7bc1f4f1 74 #define MESSAGE_COUNT 5
AzureIoTClient 0:eb1c7bc1f4f1 75
AzureIoTClient 0:eb1c7bc1f4f1 76 void iothub_client_sample_amqp_run(void)
AzureIoTClient 0:eb1c7bc1f4f1 77 {
AzureIoTClient 0:eb1c7bc1f4f1 78 IOTHUB_CLIENT_HANDLE iotHubClientHandle;
AzureIoTClient 0:eb1c7bc1f4f1 79
AzureIoTClient 0:eb1c7bc1f4f1 80 EVENT_INSTANCE messages[MESSAGE_COUNT];
AzureIoTClient 0:eb1c7bc1f4f1 81
AzureIoTClient 0:eb1c7bc1f4f1 82 callbackCounter = 0;
AzureIoTClient 0:eb1c7bc1f4f1 83 int receiveContext = 0;
AzureIoTClient 0:eb1c7bc1f4f1 84
AzureIoTClient 0:eb1c7bc1f4f1 85 (void)printf("Starting the IoTHub client sample AMQP...\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 86
AzureIoTClient 0:eb1c7bc1f4f1 87 if ((iotHubClientHandle = IoTHubClient_CreateFromConnectionString(connectionString, IoTHubTransportAmqp_ProvideTransportInterface)) == NULL)
AzureIoTClient 0:eb1c7bc1f4f1 88 {
AzureIoTClient 0:eb1c7bc1f4f1 89 (void)printf("ERROR: iotHubClientHandle is NULL!\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 90 }
AzureIoTClient 0:eb1c7bc1f4f1 91 else
AzureIoTClient 0:eb1c7bc1f4f1 92 {
AzureIoTClient 0:eb1c7bc1f4f1 93 #ifdef MBED_BUILD_TIMESTAMP
AzureIoTClient 0:eb1c7bc1f4f1 94 // For mbed add the certificate information
AzureIoTClient 0:eb1c7bc1f4f1 95 if (IoTHubClient_SetOption(iotHubClientHandle, "TrustedCerts", certificates) != IOTHUB_CLIENT_OK)
AzureIoTClient 0:eb1c7bc1f4f1 96 {
AzureIoTClient 0:eb1c7bc1f4f1 97 printf("failure to set option \"TrustedCerts\"\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 98 }
AzureIoTClient 0:eb1c7bc1f4f1 99 #endif // MBED_BUILD_TIMESTAMP
AzureIoTClient 0:eb1c7bc1f4f1 100
AzureIoTClient 0:eb1c7bc1f4f1 101 /* Setting Notification call back, so we can receive Commands. */
AzureIoTClient 0:eb1c7bc1f4f1 102 if (IoTHubClient_SetNotificationCallback(iotHubClientHandle, ReceiveNotificationCallback, &receiveContext) != IOTHUB_CLIENT_OK)
AzureIoTClient 0:eb1c7bc1f4f1 103 {
AzureIoTClient 0:eb1c7bc1f4f1 104 (void)printf("ERROR: IoTHubClient_SetNotificationCallback..........FAILED!\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 105 }
AzureIoTClient 0:eb1c7bc1f4f1 106 else
AzureIoTClient 0:eb1c7bc1f4f1 107 {
AzureIoTClient 0:eb1c7bc1f4f1 108 (void)printf("IoTHubClient_SetNotificationCallback...successful.\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 109
AzureIoTClient 0:eb1c7bc1f4f1 110 /* Now that we are ready to receive commands, let's send some messages */
AzureIoTClient 0:eb1c7bc1f4f1 111 for (int i = 0; i < MESSAGE_COUNT; i++)
AzureIoTClient 0:eb1c7bc1f4f1 112 {
AzureIoTClient 0:eb1c7bc1f4f1 113 sprintf_s(msgText, sizeof(msgText), "Message_%d_From_IoTHubClient_Over_AMQP", i);
AzureIoTClient 0:eb1c7bc1f4f1 114 if ((messages[i].messageHandle = IoTHubMessage_CreateFromByteArray((const unsigned char*)msgText, strlen(msgText))) == NULL)
AzureIoTClient 0:eb1c7bc1f4f1 115 {
AzureIoTClient 0:eb1c7bc1f4f1 116 (void)printf("ERROR: iotHubMessageHandle is NULL!\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 117 }
AzureIoTClient 0:eb1c7bc1f4f1 118 else
AzureIoTClient 0:eb1c7bc1f4f1 119 {
AzureIoTClient 0:eb1c7bc1f4f1 120 messages[i].messageTrackingId = i;
AzureIoTClient 0:eb1c7bc1f4f1 121
AzureIoTClient 0:eb1c7bc1f4f1 122 MAP_HANDLE propMap = IoTHubMessage_Properties(messages[i].messageHandle);
AzureIoTClient 0:eb1c7bc1f4f1 123 sprintf_s(propText, sizeof(propText), "PropMsg_%d", i);
AzureIoTClient 0:eb1c7bc1f4f1 124 if (Map_AddOrUpdate(propMap, "PropName", propText) != MAP_OK)
AzureIoTClient 0:eb1c7bc1f4f1 125 {
AzureIoTClient 0:eb1c7bc1f4f1 126 (void)printf("ERROR: Map_AddOrUpdate Failed!\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 127 }
AzureIoTClient 0:eb1c7bc1f4f1 128
AzureIoTClient 0:eb1c7bc1f4f1 129 if (IoTHubClient_SendEventAsync(iotHubClientHandle, messages[i].messageHandle, SendConfirmationCallback, &messages[i]) != IOTHUB_CLIENT_OK)
AzureIoTClient 0:eb1c7bc1f4f1 130 {
AzureIoTClient 0:eb1c7bc1f4f1 131 (void)printf("ERROR: IoTHubClient_SendEventAsync..........FAILED!\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 132 }
AzureIoTClient 0:eb1c7bc1f4f1 133 else
AzureIoTClient 0:eb1c7bc1f4f1 134 {
AzureIoTClient 0:eb1c7bc1f4f1 135 (void)printf("IoTHubClient_SendEventAsync accepted data for transmission to IoT Hub.\r\n");
AzureIoTClient 0:eb1c7bc1f4f1 136 }
AzureIoTClient 0:eb1c7bc1f4f1 137
AzureIoTClient 0:eb1c7bc1f4f1 138 }
AzureIoTClient 0:eb1c7bc1f4f1 139 }
AzureIoTClient 0:eb1c7bc1f4f1 140
AzureIoTClient 0:eb1c7bc1f4f1 141 /* Wait for Commands. */
AzureIoTClient 0:eb1c7bc1f4f1 142 (void)printf("Press any key to exit the application. \r\n");
AzureIoTClient 0:eb1c7bc1f4f1 143 (void)getchar();
AzureIoTClient 0:eb1c7bc1f4f1 144 }
AzureIoTClient 0:eb1c7bc1f4f1 145
AzureIoTClient 0:eb1c7bc1f4f1 146 IoTHubClient_Destroy(iotHubClientHandle);
AzureIoTClient 0:eb1c7bc1f4f1 147 }
AzureIoTClient 0:eb1c7bc1f4f1 148 }