Service layer interworking using MQTT protocol
Methods are proposed to integrate MQTT Server functionality into the oneM2M CSE, as well as to interconnect such CSE-based MQTT Servers into a network organized around a topic structure based on resource address. Methods can dynamically allocate, assign and deliver an identifier that can be used as the AE-ID by the AE, CSE and MQTT Server. The MQTT Server can be internetworked into the M2M Service Layer such that an MQTT Server is available in every Service Layer node that hosts a CSE. MQTT Server-to-Server connections can be dynamically established to facilitate traffic between Service Layer entities
1. A node comprising a processor and a memory, the node further including computer-executable instructions stored in the memory of the node which, when executed by the processor of the node, cause the node to:
receive a publish request from an application that uses a predetermined topic filter parameter related to a request for an application identifier;
in response to the predetermined topic filter parameter, publish a message for a registrar that includes a temporary client identifier (ID);
receive a message from the registrar that includes an assigned application name as payload;
provide the assigned application name to the application; and
receive a subscription request from the application including the assigned application name as part of a topic filter.
2. The node of claim 1 wherein the temporary client identifier is a null identifier.
3. The node of claim 1 , wherein the node implements a Message Queuing Telemetry Transport (MQTT) server.
4. The node of claim 3 , wherein the MQTT Server includes client functionality.
5. The node of claim 1 , wherein the registrar is a registrar Common Services Entity (CSE).
6. A node comprising a processor and a memory, the node further including computer-executable instructions stored in the memory of the node which, when executed by the processor of the node, cause the node to:
send a publish request to a server that uses a predetermined topic filter parameter related to a request for an application identifier;
receive a message from the server that includes an assigned application name as payload; and
send a subscription request to the server including the assigned application name as part of a topic filter.
7. The node of claim 6 , wherein the server is a Message Queuing Telemetry Transport (MQTT) server.
8. A node comprising a processor and a memory, the node further including computer-executable instructions stored in the memory of the node which, when executed by the processor of the node, cause the node to:
receive a subscribe request from an application with a topic filter indicating a first middle node and the application;
send a subscribe request to a server at an infrastructure node for a topic with the topic filter indicating the infrastructure node; and
receive a subscribe request from the server at the infrastructure node for the topic with the topic filter indicating the infrastructure node, wherein messages are forwarded through the first middle node between the application and the infrastructure node using the topic at the first middle node and the infrastructure node.
9. The node of claim 8 wherein the node is a second middle node.
10. The node of claim 8 , wherein the node implements a Message Queuing Telemetry Transport (MQTT) server.
11. The node of claim 10 , wherein the MQTT Server includes client functionality.
12. The node of claim 8 , wherein the server at the infrastructure node is a Message Queuing Telemetry Transport (MQTT) server.
13. A method for use by a node, wherein the node comprises a processor and memory, and wherein the node further includes computer-executable instructions stored in the memory which, when executed by the processor, perform functions of a method comprising:
receiving a publish request from an application that uses a predetermined topic filter parameter related to a request for an application identifier;
in response to the predetermined topic filter parameter, publishing a message for a registrar that includes a temporary client identifier (ID);
receiving a message from the registrar that includes an assigned application name as payload;
providing the assigned application name to the application; and
receiving a subscription request from the application including the assigned application name as part of a topic filter.
14. The method of claim 13 wherein the temporary client identifier is a null identifier.
15. The method of claim 13 , wherein the node implements a Message Queuing Telemetry Transport (MQTT) server.
16. The method of claim 15 , wherein the MQTT Server includes client functionality.
17. The method of claim 13 , wherein the registrar is a registrar Common Services Entity (CSE).
18. A method for use by a node, wherein the node comprises a processor and memory, and wherein the node further includes computer-executable instructions stored in the memory which, when executed by the processor, perform functions of a method comprising:
sending a publish request to a server that uses a predetermined topic filter parameter related to a request for an application identifier;
receiving a message from the server that includes an assigned application name as payload; and
sending a subscription request to the server including the assigned application name as part of a topic filter.
19. The method of claim 18 , wherein the node implements an application.
20. The method of claim 18 , wherein the Server is an Message Queuing Telemetry Transport (MQTT) server that includes client functionality.
21. A method for use by a node, wherein the node comprises a processor and memory, and wherein the node further includes computer-executable instructions stored in the memory which, when executed by the processor, perform functions of a method comprising:
receiving a subscribe request from an application with a topic filter indicating a first middle node and the application;
sending a subscribe request to a server at an infrastructure node for a topic with the topic filter indicating the infrastructure node; and
receiving a subscribe request from the server at the infrastructure node for the topic with the topic filter indicating the infrastructure node, wherein messages are forwarded through the first middle node between the application and the infrastructure node using the topic at the first middle node and the infrastructure node.
22. The method of claim 21 wherein the node is a second middle node.
23. The method of claim 21 , wherein the node implements a Message Queuing Telemetry Transport (MQTT) server.
24. The method of claim 23 , wherein the MQTT Server includes client functionality.
25. The method of claim 21 , wherein the server at the infrastructure node is a Message Queuing Telemetry Transport (MQTT) server.