mirror of
https://github.com/fhmq/hmq.git
synced 2026-08-30 14:24:53 +00:00
Update comm.go (#85)
This commit is contained in:
+5
-1
@@ -114,7 +114,11 @@ func delSubMap(m map[string]uint64, topic string) uint64 {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func GenUniqueId() string {
|
func GenUniqueId() string {
|
||||||
return uuid.NewV4().String()
|
id, err := uuid.NewV4()
|
||||||
|
if err != nil {
|
||||||
|
log.Error("uuid.NewV4() return error: " + err.Error())
|
||||||
|
}
|
||||||
|
return id.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
func wrapPublishPacket(packet *packets.PublishPacket) *packets.PublishPacket {
|
func wrapPublishPacket(packet *packets.PublishPacket) *packets.PublishPacket {
|
||||||
|
|||||||
Reference in New Issue
Block a user