mirrors/ctrl
mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2024-12-14 12:37:31 +00:00
Code Activity

changed copy sub subjects to use "." for uuid

Browse source
This commit is contained in:
postmannen 2022-06-10 06:34:39 +02:00
parent c86e513cc0
commit 95ce5fed3b
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
requests_copy.go
View file

@ -91,7 +91,7 @@ func (m methodREQCopySrc) handler(proc process, message Message, node string) ([
// Create a subject for one copy request
uid := uuid.New()
subProcessName = fmt.Sprintf("copySrc_%v", uid.String())
subProcessName = fmt.Sprintf("copySrc.%v", uid.String())
m := Method(subProcessName)
sub := newSubjectNoVerifyHandler(m, node)
@ -199,7 +199,7 @@ func (m methodREQCopyDst) handler(proc process, message Message, node string) ([
ctx, _ := getContextForMethodTimeout(proc.ctx, message)
// Create a subject for one copy request
subProcessName = fmt.Sprintf("copyDst_%v", cia.UUID)
subProcessName = fmt.Sprintf("copyDst.%v", cia.UUID)
m := Method(subProcessName)
sub := newSubjectNoVerifyHandler(m, node)