bsm-sdk/core
Public Access
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 3 Wiki Activity

queue

Browse Source
This commit is contained in:
zhaoxiaorong
2025-02-07 15:28:55 +08:00
parent 677f484748
commit db89284fdb
4 changed files with 151 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
queue/pulsar/pulsar.go
View File

@@ -4,8 +4,8 @@ import (
"context"
"errors"
"git.apinb.com/bsm-sdk/engine/types"
"git.apinb.com/bsm-sdk/engine/vars"
"git.apinb.com/bsm-sdk/core/types"
"git.apinb.com/bsm-sdk/core/vars"
pulsargo "github.com/apache/pulsar-client-go/pulsar"
)