Azure IoT / Mbed 2 deprecated iothub_client_sample_mqtt

IoTHub raw messaging client sample using MQTT

Dependencies:   EthernetInterface NTPClient mbed-rtos mbed wolfSSL azure_c_shared_utility iothub_client azure_umqtt_c iothub_mqtt_transport

iothub_client_sample_mqtt.c@27:7c908b91210a, 2017-01-24 (annotated)

Committer:
AzureIoTClient
Date:
Tue Jan 24 15:29:17 2017 -0800
Revision:
27:7c908b91210a
Parent:
22:27faaa37d70f
Child:
30:0a147a179e7e
1.1.5

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Azure.IoT Build 2:65c172c36cf5 1 // Copyright (c) Microsoft. All rights reserved.
Azure.IoT Build 2:65c172c36cf5 2 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
Azure.IoT Build 2:65c172c36cf5 3
Azure.IoT Build 2:65c172c36cf5 4 #include <stdio.h>
Azure.IoT Build 2:65c172c36cf5 5 #include <stdlib.h>
Azure.IoT Build 2:65c172c36cf5 6
Azure.IoT Build 2:65c172c36cf5 7 #include "iothub_client.h"
Azure.IoT Build 2:65c172c36cf5 8 #include "iothub_message.h"
AzureIoTClient 6:02304619a9fa 9 #include "azure_c_shared_utility/threadapi.h"
AzureIoTClient 6:02304619a9fa 10 #include "azure_c_shared_utility/crt_abstractions.h"
Azure.IoT Build 14:0d0177062483 11 #include "azure_c_shared_utility/platform.h"
Azure.IoT Build 2:65c172c36cf5 12 #include "iothubtransportmqtt.h"
Azure.IoT Build 2:65c172c36cf5 13
Azure.IoT Build 2:65c172c36cf5 14 #ifdef MBED_BUILD_TIMESTAMP
Azure.IoT Build 2:65c172c36cf5 15 #include "certs.h"
Azure.IoT Build 2:65c172c36cf5 16 #endif // MBED_BUILD_TIMESTAMP
Azure.IoT Build 2:65c172c36cf5 17
AzureIoTClient 7:02bc67ebbe23 18 /*String containing Hostname, Device Id & Device Key in the format: */
AzureIoTClient 7:02bc67ebbe23 19 /* "HostName=<host_name>;DeviceId=<device_id>;SharedAccessKey=<device_key>" */
AzureIoTClient 7:02bc67ebbe23 20 /* "HostName=<host_name>;DeviceId=<device_id>;SharedAccessSignature=<device_sas_token>" */
Azure.IoT Build 2:65c172c36cf5 21 static const char* connectionString = "[device connection string]";
Azure.IoT Build 2:65c172c36cf5 22
Azure.IoT Build 2:65c172c36cf5 23 static int callbackCounter;
Azure.IoT Build 2:65c172c36cf5 24 static char msgText[1024];
AzureIoTClient 6:02304619a9fa 25 static char propText[1024];
Azure.IoT Build 14:0d0177062483 26 static bool g_continueRunning;
Azure.IoT Build 2:65c172c36cf5 27 #define MESSAGE_COUNT 5
Azure.IoT Build 14:0d0177062483 28 #define DOWORK_LOOP_NUM 3
Azure.IoT Build 2:65c172c36cf5 29
Azure.IoT Build 2:65c172c36cf5 30
Azure.IoT Build 2:65c172c36cf5 31 typedef struct EVENT_INSTANCE_TAG
Azure.IoT Build 2:65c172c36cf5 32 {
Azure.IoT Build 2:65c172c36cf5 33 IOTHUB_MESSAGE_HANDLE messageHandle;
AzureIoTClient 15:2f2b3dc3ecb4 34 size_t messageTrackingId; // For tracking the messages within the user callback.
Azure.IoT Build 2:65c172c36cf5 35 } EVENT_INSTANCE;
Azure.IoT Build 2:65c172c36cf5 36
Azure.IoT Build 2:65c172c36cf5 37 static IOTHUBMESSAGE_DISPOSITION_RESULT ReceiveMessageCallback(IOTHUB_MESSAGE_HANDLE message, void* userContextCallback)
Azure.IoT Build 2:65c172c36cf5 38 {
Azure.IoT Build 2:65c172c36cf5 39 int* counter = (int*)userContextCallback;
Azure.IoT Build 2:65c172c36cf5 40 const char* buffer;
Azure.IoT Build 2:65c172c36cf5 41 size_t size;
AzureIoTClient 10:f77bb0044e11 42
Azure.IoT Build 2:65c172c36cf5 43 if (IoTHubMessage_GetByteArray(message, (const unsigned char**)&buffer, &size) != IOTHUB_MESSAGE_OK)
Azure.IoT Build 2:65c172c36cf5 44 {
Azure.IoT Build 2:65c172c36cf5 45 (void)printf("unable to retrieve the message data\r\n");
Azure.IoT Build 2:65c172c36cf5 46 }
Azure.IoT Build 2:65c172c36cf5 47 else
Azure.IoT Build 2:65c172c36cf5 48 {
Azure.IoT Build 2:65c172c36cf5 49 (void)printf("Received Message [%d] with Data: <<<%.*s>>> & Size=%d\r\n", *counter, (int)size, buffer, (int)size);
Azure.IoT Build 2:65c172c36cf5 50 // If we receive the work 'quit' then we stop running
AzureIoTClient 22:27faaa37d70f 51 if (size == (strlen("quit") * sizeof(char)) && memcmp(buffer, "quit", size) == 0)
Azure.IoT Build 2:65c172c36cf5 52 {
AzureIoTClient 10:f77bb0044e11 53 g_continueRunning = false;
Azure.IoT Build 2:65c172c36cf5 54 }
Azure.IoT Build 2:65c172c36cf5 55 }
Azure.IoT Build 2:65c172c36cf5 56
Azure.IoT Build 2:65c172c36cf5 57 // Retrieve properties from the message
Azure.IoT Build 2:65c172c36cf5 58 MAP_HANDLE mapProperties = IoTHubMessage_Properties(message);
Azure.IoT Build 2:65c172c36cf5 59 if (mapProperties != NULL)
Azure.IoT Build 2:65c172c36cf5 60 {
Azure.IoT Build 2:65c172c36cf5 61 const char*const* keys;
Azure.IoT Build 2:65c172c36cf5 62 const char*const* values;
Azure.IoT Build 2:65c172c36cf5 63 size_t propertyCount = 0;
Azure.IoT Build 2:65c172c36cf5 64 if (Map_GetInternals(mapProperties, &keys, &values, &propertyCount) == MAP_OK)
Azure.IoT Build 2:65c172c36cf5 65 {
Azure.IoT Build 2:65c172c36cf5 66 if (propertyCount > 0)
Azure.IoT Build 2:65c172c36cf5 67 {
AzureIoTClient 27:7c908b91210a 68 size_t index = 0;
AzureIoTClient 27:7c908b91210a 69 for (index = 0; index < propertyCount; index++)
Azure.IoT Build 2:65c172c36cf5 70 {
Azure.IoT Build 2:65c172c36cf5 71 (void)printf("\tKey: %s Value: %s\r\n", keys[index], values[index]);
Azure.IoT Build 2:65c172c36cf5 72 }
Azure.IoT Build 2:65c172c36cf5 73 (void)printf("\r\n");
Azure.IoT Build 2:65c172c36cf5 74 }
Azure.IoT Build 2:65c172c36cf5 75 }
Azure.IoT Build 2:65c172c36cf5 76 }
Azure.IoT Build 2:65c172c36cf5 77
Azure.IoT Build 2:65c172c36cf5 78 /* Some device specific action code goes here... */
Azure.IoT Build 2:65c172c36cf5 79 (*counter)++;
Azure.IoT Build 2:65c172c36cf5 80 return IOTHUBMESSAGE_ACCEPTED;
Azure.IoT Build 2:65c172c36cf5 81 }
Azure.IoT Build 2:65c172c36cf5 82
Azure.IoT Build 2:65c172c36cf5 83 static void SendConfirmationCallback(IOTHUB_CLIENT_CONFIRMATION_RESULT result, void* userContextCallback)
Azure.IoT Build 2:65c172c36cf5 84 {
Azure.IoT Build 2:65c172c36cf5 85 EVENT_INSTANCE* eventInstance = (EVENT_INSTANCE*)userContextCallback;
AzureIoTClient 15:2f2b3dc3ecb4 86 (void)printf("Confirmation[%d] received for message tracking id = %zu with result = %s\r\n", callbackCounter, eventInstance->messageTrackingId, ENUM_TO_STRING(IOTHUB_CLIENT_CONFIRMATION_RESULT, result));
Azure.IoT Build 2:65c172c36cf5 87 /* Some device specific action code goes here... */
Azure.IoT Build 2:65c172c36cf5 88 callbackCounter++;
Azure.IoT Build 2:65c172c36cf5 89 IoTHubMessage_Destroy(eventInstance->messageHandle);
Azure.IoT Build 2:65c172c36cf5 90 }
Azure.IoT Build 2:65c172c36cf5 91
Azure.IoT Build 2:65c172c36cf5 92 void iothub_client_sample_mqtt_run(void)
Azure.IoT Build 2:65c172c36cf5 93 {
Azure.IoT Build 2:65c172c36cf5 94 IOTHUB_CLIENT_LL_HANDLE iotHubClientHandle;
Azure.IoT Build 2:65c172c36cf5 95
Azure.IoT Build 2:65c172c36cf5 96 EVENT_INSTANCE messages[MESSAGE_COUNT];
Azure.IoT Build 2:65c172c36cf5 97
AzureIoTClient 10:f77bb0044e11 98 g_continueRunning = true;
Azure.IoT Build 2:65c172c36cf5 99 srand((unsigned int)time(NULL));
Azure.IoT Build 2:65c172c36cf5 100 double avgWindSpeed = 10.0;
Azure.IoT Build 2:65c172c36cf5 101
Azure.IoT Build 2:65c172c36cf5 102 callbackCounter = 0;
Azure.IoT Build 2:65c172c36cf5 103 int receiveContext = 0;
Azure.IoT Build 2:65c172c36cf5 104
Azure.IoT Build 2:65c172c36cf5 105 if (platform_init() != 0)
Azure.IoT Build 2:65c172c36cf5 106 {
Azure.IoT Build 2:65c172c36cf5 107 (void)printf("Failed to initialize the platform.\r\n");
Azure.IoT Build 2:65c172c36cf5 108 }
Azure.IoT Build 2:65c172c36cf5 109 else
Azure.IoT Build 2:65c172c36cf5 110 {
Azure.IoT Build 2:65c172c36cf5 111 if ((iotHubClientHandle = IoTHubClient_LL_CreateFromConnectionString(connectionString, MQTT_Protocol)) == NULL)
Azure.IoT Build 2:65c172c36cf5 112 {
Azure.IoT Build 2:65c172c36cf5 113 (void)printf("ERROR: iotHubClientHandle is NULL!\r\n");
Azure.IoT Build 2:65c172c36cf5 114 }
Azure.IoT Build 2:65c172c36cf5 115 else
Azure.IoT Build 2:65c172c36cf5 116 {
Azure.IoT Build 2:65c172c36cf5 117 bool traceOn = true;
Azure.IoT Build 2:65c172c36cf5 118 IoTHubClient_LL_SetOption(iotHubClientHandle, "logtrace", &traceOn);
Azure.IoT Build 2:65c172c36cf5 119
Azure.IoT Build 2:65c172c36cf5 120 #ifdef MBED_BUILD_TIMESTAMP
Azure.IoT Build 2:65c172c36cf5 121 // For mbed add the certificate information
Azure.IoT Build 2:65c172c36cf5 122 if (IoTHubClient_LL_SetOption(iotHubClientHandle, "TrustedCerts", certificates) != IOTHUB_CLIENT_OK)
Azure.IoT Build 2:65c172c36cf5 123 {
Azure.IoT Build 2:65c172c36cf5 124 printf("failure to set option \"TrustedCerts\"\r\n");
Azure.IoT Build 2:65c172c36cf5 125 }
Azure.IoT Build 2:65c172c36cf5 126 #endif // MBED_BUILD_TIMESTAMP
Azure.IoT Build 2:65c172c36cf5 127
Azure.IoT Build 2:65c172c36cf5 128 /* Setting Message call back, so we can receive Commands. */
Azure.IoT Build 2:65c172c36cf5 129 if (IoTHubClient_LL_SetMessageCallback(iotHubClientHandle, ReceiveMessageCallback, &receiveContext) != IOTHUB_CLIENT_OK)
Azure.IoT Build 2:65c172c36cf5 130 {
Azure.IoT Build 2:65c172c36cf5 131 (void)printf("ERROR: IoTHubClient_LL_SetMessageCallback..........FAILED!\r\n");
Azure.IoT Build 2:65c172c36cf5 132 }
Azure.IoT Build 2:65c172c36cf5 133 else
Azure.IoT Build 2:65c172c36cf5 134 {
Azure.IoT Build 2:65c172c36cf5 135 (void)printf("IoTHubClient_LL_SetMessageCallback...successful.\r\n");
Azure.IoT Build 2:65c172c36cf5 136
Azure.IoT Build 2:65c172c36cf5 137 /* Now that we are ready to receive commands, let's send some messages */
AzureIoTClient 10:f77bb0044e11 138 size_t iterator = 0;
AzureIoTClient 10:f77bb0044e11 139 do
Azure.IoT Build 2:65c172c36cf5 140 {
AzureIoTClient 10:f77bb0044e11 141 if (iterator < MESSAGE_COUNT)
Azure.IoT Build 2:65c172c36cf5 142 {
AzureIoTClient 10:f77bb0044e11 143 sprintf_s(msgText, sizeof(msgText), "{\"deviceId\":\"myFirstDevice\",\"windSpeed\":%.2f}", avgWindSpeed + (rand() % 4 + 2));
AzureIoTClient 10:f77bb0044e11 144 if ((messages[iterator].messageHandle = IoTHubMessage_CreateFromByteArray((const unsigned char*)msgText, strlen(msgText))) == NULL)
AzureIoTClient 6:02304619a9fa 145 {
AzureIoTClient 10:f77bb0044e11 146 (void)printf("ERROR: iotHubMessageHandle is NULL!\r\n");
Azure.IoT Build 2:65c172c36cf5 147 }
Azure.IoT Build 2:65c172c36cf5 148 else
Azure.IoT Build 2:65c172c36cf5 149 {
AzureIoTClient 10:f77bb0044e11 150 messages[iterator].messageTrackingId = iterator;
AzureIoTClient 10:f77bb0044e11 151 MAP_HANDLE propMap = IoTHubMessage_Properties(messages[iterator].messageHandle);
AzureIoTClient 15:2f2b3dc3ecb4 152 (void)sprintf_s(propText, sizeof(propText), "PropMsg_%zu", iterator);
AzureIoTClient 10:f77bb0044e11 153 if (Map_AddOrUpdate(propMap, "PropName", propText) != MAP_OK)
AzureIoTClient 10:f77bb0044e11 154 {
AzureIoTClient 10:f77bb0044e11 155 (void)printf("ERROR: Map_AddOrUpdate Failed!\r\n");
AzureIoTClient 10:f77bb0044e11 156 }
AzureIoTClient 10:f77bb0044e11 157
AzureIoTClient 10:f77bb0044e11 158 if (IoTHubClient_LL_SendEventAsync(iotHubClientHandle, messages[iterator].messageHandle, SendConfirmationCallback, &messages[iterator]) != IOTHUB_CLIENT_OK)
AzureIoTClient 10:f77bb0044e11 159 {
AzureIoTClient 10:f77bb0044e11 160 (void)printf("ERROR: IoTHubClient_LL_SendEventAsync..........FAILED!\r\n");
AzureIoTClient 10:f77bb0044e11 161 }
AzureIoTClient 10:f77bb0044e11 162 else
AzureIoTClient 10:f77bb0044e11 163 {
AzureIoTClient 10:f77bb0044e11 164 (void)printf("IoTHubClient_LL_SendEventAsync accepted message [%d] for transmission to IoT Hub.\r\n", (int)iterator);
AzureIoTClient 10:f77bb0044e11 165 }
Azure.IoT Build 2:65c172c36cf5 166 }
Azure.IoT Build 2:65c172c36cf5 167 }
AzureIoTClient 10:f77bb0044e11 168 IoTHubClient_LL_DoWork(iotHubClientHandle);
AzureIoTClient 10:f77bb0044e11 169 ThreadAPI_Sleep(1);
Azure.IoT Build 2:65c172c36cf5 170
AzureIoTClient 10:f77bb0044e11 171 iterator++;
AzureIoTClient 10:f77bb0044e11 172 } while (g_continueRunning);
Azure.IoT Build 14:0d0177062483 173
Azure.IoT Build 14:0d0177062483 174 (void)printf("iothub_client_sample_mqtt has gotten quit message, call DoWork %d more time to complete final sending...\r\n", DOWORK_LOOP_NUM);
AzureIoTClient 27:7c908b91210a 175 size_t index = 0;
AzureIoTClient 27:7c908b91210a 176 for (index = 0; index < DOWORK_LOOP_NUM; index++)
Azure.IoT Build 14:0d0177062483 177 {
Azure.IoT Build 14:0d0177062483 178 IoTHubClient_LL_DoWork(iotHubClientHandle);
Azure.IoT Build 14:0d0177062483 179 ThreadAPI_Sleep(1);
Azure.IoT Build 14:0d0177062483 180 }
Azure.IoT Build 2:65c172c36cf5 181 }
Azure.IoT Build 2:65c172c36cf5 182 IoTHubClient_LL_Destroy(iotHubClientHandle);
Azure.IoT Build 2:65c172c36cf5 183 }
Azure.IoT Build 2:65c172c36cf5 184 platform_deinit();
Azure.IoT Build 2:65c172c36cf5 185 }
Azure.IoT Build 2:65c172c36cf5 186 }
AzureIoTClient 10:f77bb0044e11 187
AzureIoTClient 10:f77bb0044e11 188 int main(void)
AzureIoTClient 10:f77bb0044e11 189 {
AzureIoTClient 10:f77bb0044e11 190 iothub_client_sample_mqtt_run();
AzureIoTClient 10:f77bb0044e11 191 return 0;
AzureIoTClient 10:f77bb0044e11 192 }