Azure IoT
iothub_ll_telemetry_sample
Diff: iothub_ll_telemetry_sample.c
- Revision:
- 3:c88858e5d52c
- Parent:
- 2:2b31d7ad244c
- Child:
- 4:f08837288a37
--- a/iothub_ll_telemetry_sample.c Mon Apr 16 14:28:30 2018 -0700
+++ b/iothub_ll_telemetry_sample.c Tue Jun 26 19:16:42 2018 -0700
@@ -1,16 +1,25 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+// CAVEAT: This sample is to demonstrate azure IoT client concepts only and is not a guide design principles or style
+// Checking of return codes and error values shall be omitted for brevity. Please practice sound engineering practices
+// when writing production code.
+
#include <stdio.h>
#include <stdlib.h>
-#include "iothub_client.h"
+#include "iothub.h"
+#include "iothub_device_client_ll.h"
#include "iothub_client_options.h"
#include "iothub_message.h"
#include "azure_c_shared_utility/threadapi.h"
#include "azure_c_shared_utility/crt_abstractions.h"
-#include "azure_c_shared_utility/platform.h"
#include "azure_c_shared_utility/shared_util_options.h"
+#ifdef SET_TRUSTED_CERT_IN_SAMPLES
+#include "certs.h"
+#endif // SET_TRUSTED_CERT_IN_SAMPLES
+
/* This sample uses the _LL APIs of iothub_client for example purposes.
Simply changing the using the convenience layer (functions not having _LL)
and removing calls to _DoWork will yield the same results. */
@@ -57,6 +66,21 @@
(void)printf("Confirmation callback received for message %zu with result %s\r\n", g_message_count_send_confirmations, ENUM_TO_STRING(IOTHUB_CLIENT_CONFIRMATION_RESULT, result));
}
+static void connection_status_callback(IOTHUB_CLIENT_CONNECTION_STATUS result, IOTHUB_CLIENT_CONNECTION_STATUS_REASON reason, void* user_context)
+{
+ (void)reason;
+ (void)user_context;
+ // This sample DOES NOT take into consideration network outages.
+ if (result == IOTHUB_CLIENT_CONNECTION_AUTHENTICATED)
+ {
+ (void)printf("The device client is connected to iothub\r\n");
+ }
+ else
+ {
+ (void)printf("The device client has been disconnected\r\n");
+ }
+}
+
int main(void)
{
IOTHUB_CLIENT_TRANSPORT_PROVIDER protocol;
@@ -81,77 +105,84 @@
protocol = HTTP_Protocol;
#endif // SAMPLE_HTTP
- IOTHUB_CLIENT_LL_HANDLE iothub_ll_handle;
+ // Used to initialize IoTHub SDK subsystem
+ (void)IoTHub_Init();
- // Used to initialize IoTHub SDK subsystem
- (void)platform_init();
+ IOTHUB_DEVICE_CLIENT_LL_HANDLE device_ll_handle;
- (void)printf("Creating IoTHub handle\r\n");
+ (void)printf("Creating IoTHub Device handle\r\n");
// Create the iothub handle here
- iothub_ll_handle = IoTHubClient_LL_CreateFromConnectionString(connectionString, protocol);
+ device_ll_handle = IoTHubDeviceClient_LL_CreateFromConnectionString(connectionString, protocol);
+ if (device_ll_handle == NULL)
+ {
+ (void)printf("Failure createing Iothub device. Hint: Check you connection string.\r\n");
+ }
+ else
+ {
+ // Set any option that are neccessary.
+ // For available options please see the iothub_sdk_options.md documentation
- // Set any option that are neccessary.
- // For available options please see the iothub_sdk_options.md documentation
-
- //bool traceOn = true;
- //IoTHubClient_LL_SetOption(iothub_ll_handle, OPTION_LOG_TRACE, &traceOn);
+ bool traceOn = true;
+ IoTHubDeviceClient_LL_SetOption(device_ll_handle, OPTION_LOG_TRACE, &traceOn);
#ifdef SET_TRUSTED_CERT_IN_SAMPLES
- // Setting the Trusted Certificate. This is only necessary on system with without
- // built in certificate stores.
- IoTHubClient_LL_SetOption(iothub_ll_handle, OPTION_TRUSTED_CERT, certificates);
+ // Setting the Trusted Certificate. This is only necessary on system with without
+ // built in certificate stores.
+ IoTHubDeviceClient_LL_SetOption(device_ll_handle, OPTION_TRUSTED_CERT, certificates);
#endif // SET_TRUSTED_CERT_IN_SAMPLES
#if defined SAMPLE_MQTT || defined SAMPLE_MQTT_WS
- //Setting the auto URL Encoder (recommended for MQTT). Please use this option unless
- //you are URL Encoding inputs yourself.
- //ONLY valid for use with MQTT
- //bool urlEncodeOn = true;
- //IoTHubClient_LL_SetOption(iothub_ll_handle, OPTION_AUTO_URL_ENCODE_DECODE, &urlEncodeOn);
+ //Setting the auto URL Encoder (recommended for MQTT). Please use this option unless
+ //you are URL Encoding inputs yourself.
+ //ONLY valid for use with MQTT
+ //bool urlEncodeOn = true;
+ //IoTHubDeviceClient_LL_SetOption(iothub_ll_handle, OPTION_AUTO_URL_ENCODE_DECODE, &urlEncodeOn);
#endif
- do
- {
- if (messages_sent < MESSAGE_COUNT)
- {
- // Construct the iothub message from a string or a byte array
- message_handle = IoTHubMessage_CreateFromString(telemetry_msg);
- //message_handle = IoTHubMessage_CreateFromByteArray((const unsigned char*)msgText, strlen(msgText)));
+ // Setting connection status callback to get indication of connection to iothub
+ (void)IoTHubDeviceClient_LL_SetConnectionStatusCallback(device_ll_handle, connection_status_callback, NULL);
- // Set Message property
- (void)IoTHubMessage_SetMessageId(message_handle, "MSG_ID");
- (void)IoTHubMessage_SetCorrelationId(message_handle, "CORE_ID");
- (void)IoTHubMessage_SetContentTypeSystemProperty(message_handle, "application%2fjson");
- (void)IoTHubMessage_SetContentEncodingSystemProperty(message_handle, "utf-8");
+ do
+ {
+ if (messages_sent < MESSAGE_COUNT)
+ {
+ // Construct the iothub message from a string or a byte array
+ message_handle = IoTHubMessage_CreateFromString(telemetry_msg);
+ //message_handle = IoTHubMessage_CreateFromByteArray((const unsigned char*)msgText, strlen(msgText)));
- // Add custom properties to message
- MAP_HANDLE propMap = IoTHubMessage_Properties(message_handle);
- Map_AddOrUpdate(propMap, "property_key", "property_value");
+ // Set Message property
+ /*(void)IoTHubMessage_SetMessageId(message_handle, "MSG_ID");
+ (void)IoTHubMessage_SetCorrelationId(message_handle, "CORE_ID");
+ (void)IoTHubMessage_SetContentTypeSystemProperty(message_handle, "application%2fjson");
+ (void)IoTHubMessage_SetContentEncodingSystemProperty(message_handle, "utf-8");*/
- (void)printf("Sending message %d to IoTHub\r\n", (int)(messages_sent + 1));
- IoTHubClient_LL_SendEventAsync(iothub_ll_handle, message_handle, send_confirm_callback, NULL);
+ // Add custom properties to message
+ (void)IoTHubMessage_SetProperty(message_handle, "property_key", "property_value");
- // The message is copied to the sdk so the we can destroy it
- IoTHubMessage_Destroy(message_handle);
+ (void)printf("Sending message %d to IoTHub\r\n", (int)(messages_sent + 1));
+ IoTHubDeviceClient_LL_SendEventAsync(device_ll_handle, message_handle, send_confirm_callback, NULL);
- messages_sent++;
- }
- else if (g_message_count_send_confirmations >= MESSAGE_COUNT)
- {
- // After all messages are all received stop running
- g_continueRunning = false;
- }
+ // The message is copied to the sdk so the we can destroy it
+ IoTHubMessage_Destroy(message_handle);
- IoTHubClient_LL_DoWork(iothub_ll_handle);
- ThreadAPI_Sleep(1);
-
- } while (g_continueRunning);
+ messages_sent++;
+ }
+ else if (g_message_count_send_confirmations >= MESSAGE_COUNT)
+ {
+ // After all messages are all received stop running
+ g_continueRunning = false;
+ }
- // Clean up the iothub sdk handle
- IoTHubClient_LL_Destroy(iothub_ll_handle);
+ IoTHubDeviceClient_LL_DoWork(device_ll_handle);
+ ThreadAPI_Sleep(1);
+
+ } while (g_continueRunning);
+ // Clean up the iothub sdk handle
+ IoTHubDeviceClient_LL_Destroy(device_ll_handle);
+ }
// Free all the sdk subsystem
- platform_deinit();
+ IoTHub_Deinit();
printf("Press any key to continue");
getchar();