Ver código fonte

Add 'PUBLISH_PACKET(QoS, Topic, PacketId)' macro

Feng Lee 6 anos atrás
pai
commit
795fe4e0bc
3 arquivos alterados com 7 adições e 0 exclusões
  1. 7 0
      include/emqx_mqtt.hrl
  2. 0 0
      src/emqx_connection.erl
  3. 0 0
      src/emqx_ws_connection.erl

+ 7 - 0
include/emqx_mqtt.hrl

@@ -351,6 +351,13 @@
                  variable = #mqtt_packet_publish{packet_id = PacketId}
                  variable = #mqtt_packet_publish{packet_id = PacketId}
                 }).
                 }).
 
 
+-define(PUBLISH_PACKET(QoS, Topic, PacketId),
+    #mqtt_packet{header   = #mqtt_packet_header{type = ?PUBLISH,
+                                                qos  = QoS},
+                 variable = #mqtt_packet_publish{topic_name = Topic,
+                                                 packet_id  = PacketId}
+                }).
+
 -define(PUBLISH_PACKET(QoS, Topic, PacketId, Payload),
 -define(PUBLISH_PACKET(QoS, Topic, PacketId, Payload),
     #mqtt_packet{header   = #mqtt_packet_header{type = ?PUBLISH,
     #mqtt_packet{header   = #mqtt_packet_header{type = ?PUBLISH,
                                                 qos  = QoS},
                                                 qos  = QoS},

src/emqx_channel.erl → src/emqx_connection.erl


src/emqx_ws_channel.erl → src/emqx_ws_connection.erl