ymnuk/yt-function-sdk-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 23 Wiki Activity

Change "ChanSubscribe" to "ChanQueueSubscribe"

Browse Source
This commit is contained in:
ymnuk 2022-11-03 19:52:23 +03:00
parent 1dc19f9e72
commit c06201b8eb
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ytfunction.go
View File

@ -233,7 +233,8 @@ func (serve *Serve) Run() (err error) {
serve.queueCallback = fmt.Sprintf("%s.%s.%x", serve.projectName, serve.moduleName, rnd)
fmt.Println(serve.queueCallback)
serve.chanQueueCallback = make(chan *nats.Msg)
serve.subj, err = serve.nc.ChanSubscribe(serve.queueCallback, serve.chanQueueCallback)
serve.subj, err = serve.nc.ChanQueueSubscribe(serve.queueCallback, serve.projectName+"."+serve.moduleName, serve.chanQueueCallback)
//serve.subj, err = serve.nc.ChanSubscribe(serve.queueCallback, serve.chanQueueCallback)
//serve.subj.SetPendingLimits(1024*500, 1024*5000)
go serve.worker()
return
@ -304,7 +305,8 @@ func (serve *Serve) RegisterFunctionWithTimeout(funcName string, timeout time.Du
F: f,
}
fDesc.inputChan = make(chan *nats.Msg)
fDesc.subj, err = serve.nc.ChanSubscribe(fmt.Sprintf("%s.%s.%s", serve.projectName, serve.moduleName, funcName), fDesc.inputChan)
fDesc.subj, err = serve.nc.ChanQueueSubscribe(fmt.Sprintf("%s.%s.%s", serve.projectName, serve.moduleName, funcName), serve.projectName+"."+serve.moduleName, fDesc.inputChan)
//fDesc.subj, err = serve.nc.ChanSubscribe(fmt.Sprintf("%s.%s.%s", serve.projectName, serve.moduleName, funcName), fDesc.inputChan)
fDesc.conn = serve.nc
fDesc.timeout = timeout
fDesc.acceptFunc = serve.acceptVerify