From 95ce5fed3bda0105a74a37730d95010887274987 Mon Sep 17 00:00:00 2001 From: postmannen Date: Fri, 10 Jun 2022 06:34:39 +0200 Subject: [PATCH] changed copy sub subjects to use "." for uuid --- requests_copy.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/requests_copy.go b/requests_copy.go index 9a0441c..c0ca3d8 100644 --- a/requests_copy.go +++ b/requests_copy.go @@ -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)