Smart event monitoring of IoT devices using message queue

Abstract

A system for routing Internet-of-Things (IoT) device notifications, or a method therefore are described. For example, a system includes a processor; and computer-readable instructions that, when executed by the processor, cause the system to perform operations including receiving, from a notification customer, preferences for a selection of notifications associated with IoT devices; storing each notification of the notifications in one or more message queues, the message queues being associated with the preferences; and transmitting the selection of the notifications to the notification customer, wherein the selection of notifications comprises a subset of the notifications.

What is claimed is: 
     
       1. A system comprising:
 a processor; and 
 computer-readable instructions that, when executed by the processor, cause the system to perform operations including:
 receiving, from notification customers, customer preferences for routing a selection of notifications associated with Internet-of-Things (IoT) devices, the customer preferences including a first customer preference, a second customer preference, a third customer preference, and a fourth customer preference, the first customer preference received from a first notification customer of the notification customers, the second customer preference received from a second notification customer of the notification customers, the third customer preference received from a third notification customer of the notification customers, the fourth customer preference received from a fourth notification customer of the notification customers; 
 utilizing the first customer preference to configure a first message queue to have a notification type configuration option satisfying a notification type parameter, no preferences of the second notification customer, the third notification customer, or the fourth notification customer being received for the notification type configuration option of the first message queue; 
 utilizing the second customer preference to configure a second message queue to have a notification priority configuration option satisfying a notification priority parameter, no preferences of the first notification customer, the third notification customer, or the fourth notification customer being received for the notification priority configuration option of the second message queue; 
 utilizing the third customer preference to configure a third message queue to have a IoT device location configuration option satisfying an IoT device location parameter, no preferences of the first notification customer, the second notification customer, or the fourth notification customer being received for the IoT device location configuration option of the third message queue; 
 utilizing the fourth customer preference that to configure a fourth message queue to have an IoT device type configuration option satisfying an IoT device type parameter, no preferences of the first notification customer, the second notification customer, or the third notification customer being received for the IoT device type configuration option of the fourth message queue; 
 receiving first notifications with a first received parameter that includes the notification type parameter or the notification priority parameter; 
 receiving second notifications with a second received parameter that includes the IoT device location parameter or the IoT device type parameter; 
 utilizing the notification type configuration option or the notification priority configuration option to perform a first message queue selection; 
 utilizing the IoT device location configuration option or the IoT device type configuration option to perform a second message queue selection; 
 storing the first notifications in the first message queue or the second message queue satisfying the first received parameter based on the first message queue selection; 
 storing the second notifications in the third message queue or the fourth message queue satisfying the second received parameter based on the second message queue selection; and 
 transmitting the selection of notifications, the selection of notifications comprising at least one of i) the first notifications being transmitted from the first message queue or the second message queue, and, respectively, to the first notification customer or the second notification customer, or ii) the second notifications being transmitted from the second message queue or the third message queue, and, respectively, to the third notification customer or the fourth notification customer. 
 
 
     
     
       2. The system of  claim 1 , wherein
 the first message queue, the second message queue, the third message queue, and the fourth message queue comprise a first event streaming message queue, a second event streaming message queue, a third event streaming message queue, and a fourth event streaming message queue, respectively. 
 
     
     
       3. The system of  claim 1 , wherein transmitting the selection of notifications further comprises:
 transmitting the first notifications from the first message queue and to the first notification customer; and 
 transmitting the second notifications from the second message queue and to the third notification customer, and 
 wherein the computer-readable instructions, when executed by the processor, further cause the system to perform operations including: 
 receiving an error message, the error message indicating the first notifications were not received by the first notification customer; and 
 retransmitting, to the first notification customer, the first notifications. 
 
     
     
       4. The system of  claim 1 , wherein receiving the first notifications further comprises retrieving, by a service interposed between a service capability exposure function (SCEF) and the notification customers, the first notifications. 
     
     
       5. The system of  claim 1 , wherein:
 a service capability server (SCS) node comprising the first message queue and the second message queue is configured to communicate based on different IoT protocols associated with different IoT devices that transmit the selection of notifications; and 
 the SCS node is re-configurable by programming the SCS node to support the different IoT protocols. 
 
     
     
       6. The system of  claim 1 , wherein a service capability server (SCS) node comprising the first message queue and the second message queue is re-configurable by programming the SCS node to support an IoT protocol associated IoT devices. 
     
     
       7. The system of  claim 1 , wherein the first notifications are associated with notification type, and third notifications are associated with other notification types, and
 wherein utilizing the first customer preference further comprises utilizing the first customer preference to configure the first message queue to i) store the first notifications, and ii) not store the third notifications. 
 
     
     
       8. The system of  claim 1 , wherein the second notifications are associated with an IoT device type, and third notifications are associated with other IoT device types, and
 wherein utilizing the second customer preference further comprises utilizing the second customer preference to configure the second message queue to i) store the second notifications, and ii) not store the third notifications. 
 
     
     
       9. A method comprising:
 receiving, from notification customers, customer preferences for routing a selection of notifications associated with Internet-of-Things (IoT) devices, the customer preferences including a first customer preference, a second customer preference, a third customer preference, and a fourth customer preference, the first customer preference received from a first notification customer of the notification customers, the second customer preference received from a second notification customer of the notification customers, the third customer preference received from a third notification customer of the notification customers, the fourth customer preference received from a fourth notification customer of the notification customers; 
 utilizing the first customer preference to configure a first message queue to have a notification type configuration option satisfying a notification type parameter, no preferences of the second notification customer, the third notification customer, or the fourth notification customer being received for the notification type configuration option of the first message queue; 
 utilizing the second customer preference to configure a second message queue to have a notification priority configuration option satisfying a notification priority parameter, no preferences of the first notification customer, the third notification customer, or the fourth notification customer being received for the notification priority configuration option of the second message queue; 
 utilizing the third customer preference to configure a third message queue to have a IoT device location configuration option satisfying an IoT device location parameter, no preferences of the first notification customer, the second notification customer, or the fourth notification customer being received for the IoT device location configuration option of the third message queue; 
 utilizing the fourth customer preference that to configure a fourth message queue to have an IoT device type configuration option satisfying an IoT device type parameter, no preferences of the first notification customer, the second notification customer, or the third notification customer being received for the IoT device type configuration option of the fourth message queue; 
 receiving first notifications with a first received parameter that includes the notification type parameter or the notification priority parameter; 
 receiving second notifications with a second received parameter that includes the IoT device location parameter or the IoT device type parameter; 
 utilizing the notification type configuration option or the notification priority configuration option to perform a first message queue selection; 
 utilizing the IoT device location configuration option or the IoT device type configuration option to perform a second message queue selection; 
 storing the first notifications in the first message queue or the second message queue satisfying the first received parameter based on the first message queue selection; 
 storing the second notifications in the third message queue or the fourth message queue satisfying the second received parameter based on the second message queue selection; and 
 transmitting the selection of notifications, the selection of notifications comprising at least one of i) the first notifications being transmitted from the first message queue or the second message queue, and, respectively, to the first notification customer or the second notification customer, or ii) the second notifications being transmitted from the second message queue or the third message queue, and, respectively, to the third notification customer or the fourth notification customer. 
 
     
     
       10. The method of  claim 9 , wherein the first message queue, the second message queue, the third message queue, and the fourth message queue comprise a first event streaming message queue, a second event streaming message queue, a third event streaming message queue, and a fourth event streaming message queue, respectively. 
     
     
       11. The method of  claim 9 , wherein transmitting the selection of notifications further comprises:
 transmitting the first notifications from the first message queue and to the first notification customer; and 
 transmitting the second notifications from the second message queue and to the third notification customer, 
 
       further comprising:
 receiving an error message, the error message indicating the first notifications were not received by the first notification customer; and 
 retransmitting, to the first notification customer, the first notifications. 
 
     
     
       12. The method of  claim 9 , wherein receiving the first notifications further comprises retrieving, by a service interposed between a service capability exposure function (SCEF) and the notification customers, the first notifications. 
     
     
       13. The method of  claim 9 , wherein the first notifications are associated with a notification type, and third notifications are associated with other notification types, and
 wherein utilizing the first customer preference further comprises utilizing the first customer preference to configure the first message queue to i) store the first notifications, and ii) not store the third notifications. 
 
     
     
       14. The method of  claim 9 , wherein the second notifications are associated with an IoT device type, and third notifications are associated with other IoT device types, and
 wherein utilizing the second customer preference further comprises utilizing the second customer preference to configure the second message queue to i) store the second notifications, and ii) not store the third notifications. 
 
     
     
       15. One or more non-transitory computer-readable media storing instructions executable by one or more processors, wherein the instructions, when executed, cause the one or more processors to perform operations including:
 receiving, from notification customers, customer preferences for routing a selection of notifications associated with Internet-of-Things (IoT) devices, the customer preferences including a first customer preference, a second customer preference, a third customer preference, and a fourth customer preference, the first customer preference received from a first notification customer of the notification customers, the second customer preference received from a second notification customer of the notification customers, the third customer preference received from a third notification customer of the notification customers, the fourth customer preference received from a fourth notification customer of the notification customers; 
 utilizing the first customer preference to configure a first message queue to have a notification type configuration option satisfying a notification type parameter, no preferences of the second notification customer, the third notification customer, or the fourth notification customer being received for the notification type configuration option of the first message queue; 
 utilizing the second customer preference to configure a second message queue to have a notification priority configuration option satisfying a notification priority parameter, no preferences of the first notification customer, the third notification customer, or the fourth notification customer being received for the notification priority configuration option of the second message queue; 
 utilizing the third customer preference to configure a third message queue to have a IoT device location configuration option satisfying an IoT device location parameter, no preferences of the first notification customer, the second notification customer, or the fourth notification customer being received for the IoT device location configuration option of the third message queue; 
 utilizing the fourth customer preference that to configure a fourth message queue to have an IoT device type configuration option satisfying an IoT device type parameter, no preferences of the first notification customer, the second notification customer, or the third notification customer being received for the IoT device type configuration option of the fourth message queue; 
 receiving first notifications with a first received parameter that includes the notification type parameter or the notification priority parameter; 
 receiving second notifications with a second received parameter that includes the IoT device location parameter or the IoT device type parameter; 
 utilizing the notification type configuration option or the notification priority configuration option to perform a first message queue selection; 
 utilizing the IoT device location configuration option or the IoT device type configuration option to perform a second message queue selection; 
 storing the first notifications in the first message queue or the second message queue satisfying the first received parameter based on the first message queue selection; 
 storing the second notifications in the third message queue or the fourth message queue satisfying the second received parameter based on the second message queue selection; and 
 transmitting the selection of notifications, the selection of notifications comprising at least one of i) the first notifications being transmitted from the first message queue or the second message queue, and, respectively, to the first notification customer or the second notification customer, or ii) the second notifications being transmitted from the second message queue or the third message queue, and, respectively, to the third notification customer or the fourth notification customer. 
 
     
     
       16. The one or more non-transitory computer-readable media of  claim 15 , wherein the first message queue, the second message queue, the third message queue, and the fourth message queue comprise a first event streaming message queue, a second event streaming message queue, a third event streaming message queue, and a fourth event streaming message queue, respectively. 
     
     
       17. The one or more non-transitory computer-readable media of  claim 15 , wherein transmitting the selection of notifications further comprises:
 transmitting the first notifications from the first message queue and to the first notification customer; and 
 transmitting the second notifications from the second message queue and to the third notification customer, 
 
       the operations further including: 
       receiving an error message, the error message indicating the first notifications were not received by the first notification customer; and 
       retransmitting, to the first notification customer, the first notifications. 
     
     
       18. The one or more non-transitory computer-readable media of  claim 15 , wherein receiving the first notifications further comprises retrieving, by a service interposed between a service capability exposure function (SCEF) and the notification customers, the first notifications. 
     
     
       19. The one or more non-transitory computer-readable media of  claim 15 , wherein the first notifications are associated with a notification type, and third notifications are associated with other notification types, and
 wherein utilizing the first customer preference further comprises utilizing the first customer preference to configure the first message queue to i) store the first notifications, and ii) not store the third notifications. 
 
     
     
       20. The one or more non-transitory computer-readable media of  claim 15 , wherein the second notifications are associated with an IoT device type, and third notifications are associated with other IoT device types, and
 wherein utilizing the second customer preference further comprises utilizing the second customer preference to configure the second message queue to i) store the second notifications, and ii) not store the third notifications.