package/mq
1
0
Fork 0
mirror of https://github.com/oarkflow/mq.git synced 2025-09-26 20:11:16 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
sujit
2025-07-31 14:26:08 +05:45
parent 5045eddb33
commit ee2fa5dcbc
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
ctx.go
View File

@@ -10,7 +10,7 @@ import (
"sync" "sync"
"github.com/oarkflow/errors" "github.com/oarkflow/errors"
"github.com/oarkflow/xid" "github.com/oarkflow/xid/wuid"
"github.com/oarkflow/mq/consts" "github.com/oarkflow/mq/consts"
"github.com/oarkflow/mq/storage" "github.com/oarkflow/mq/storage"
@@ -90,7 +90,7 @@ func GetPublisherID(ctx context.Context) (string, bool) {
} }
func NewID() string { func NewID() string {
return xid.New().String() return wuid.New().String()
} }
func createTLSConnection(addr, certPath, keyPath string, caPath ...string) (net.Conn, error) { func createTLSConnection(addr, certPath, keyPath string, caPath ...string) (net.Conn, error) {