iuu/go-mqtt
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

代码整理

Browse Source
This commit is contained in:
建超
2024-08-21 17:47:59 +08:00
parent 0b06721605
commit a1279df8d0
2 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
.idea/workspace.xml generated
View File

@@ -4,7 +4,10 @@
<option name="autoReloadType" value="ALL" /> <option name="autoReloadType" value="ALL" />
</component> </component>
<component name="ChangeListManager"> <component name="ChangeListManager">
<list default="true" id="ff023c79-4fb4-4406-9e35-b6efd50334a5" name="更改" comment="" /> <list default="true" id="ff023c79-4fb4-4406-9e35-b6efd50334a5" name="更改" comment="">
<change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
<change beforePath="$PROJECT_DIR$/hooks/debug/debug.go" beforeDir="false" afterPath="$PROJECT_DIR$/hooks/debug/debug.go" afterDir="false" />
</list>
<option name="SHOW_DIALOG" value="false" /> <option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" /> <option name="HIGHLIGHT_CONFLICTS" value="true" />
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" /> <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />

8
hooks/debug/debug.go
View File

@@ -102,22 +102,22 @@ func (h *Hook) OnRetainMessage(cl *mqtt.Client, pk packets.Packet, r int64) {
// OnQosPublish is called when a publish packet with Qos is issued to a subscriber. // OnQosPublish is called when a publish packet with Qos is issued to a subscriber.
func (h *Hook) OnQosPublish(cl *mqtt.Client, pk packets.Packet, sent int64, resends int) { func (h *Hook) OnQosPublish(cl *mqtt.Client, pk packets.Packet, sent int64, resends int) {
h.Log.Debug("inflight out", "m", h.packetMeta(pk)) h.Log.Debug("在飞行中---消息已经发出但尚未收到确认", "m", h.packetMeta(pk))
} }
// OnQosComplete is called when the Qos flow for a message has been completed. // OnQosComplete is called when the Qos flow for a message has been completed.
func (h *Hook) OnQosComplete(cl *mqtt.Client, pk packets.Packet) { func (h *Hook) OnQosComplete(cl *mqtt.Client, pk packets.Packet) {
h.Log.Debug("inflight complete", "m", h.packetMeta(pk)) h.Log.Debug("飞行完成---消息已经成功发送并得到了确认", "m", h.packetMeta(pk))
} }
// OnQosDropped is called the Qos flow for a message expires. // OnQosDropped is called the Qos flow for a message expires.
func (h *Hook) OnQosDropped(cl *mqtt.Client, pk packets.Packet) { func (h *Hook) OnQosDropped(cl *mqtt.Client, pk packets.Packet) {
h.Log.Debug("inflight dropped", "m", h.packetMeta(pk)) h.Log.Debug("飞行丢弃---消息在传输过程中被丢弃", "m", h.packetMeta(pk))
} }
// OnLWTSent is called when a Will Message has been issued from a disconnecting client. // OnLWTSent is called when a Will Message has been issued from a disconnecting client.
func (h *Hook) OnLWTSent(cl *mqtt.Client, pk packets.Packet) { func (h *Hook) OnLWTSent(cl *mqtt.Client, pk packets.Packet) {
h.Log.Debug("sent lwt for client", "method", "OnLWTSent", "client", cl.ID) h.Log.Debug("sent lwt for client 遗嘱", "method", "OnLWTSent", "client", cl.ID)
} }
// OnRetainedExpired is called when the server clears expired retained messages. // OnRetainedExpired is called when the server clears expired retained messages.