mirrors/ctrl
1
0
Fork 0
mirror of https://github.com/postmannen/ctrl.git synced 2025-03-31 01:24:31 +00:00
Code Activity

added acktimeout and replies to the copysub messages

Browse source
This commit is contained in:
postmannen 2022-12-02 10:04:20 +01:00
parent 7c7f622044
commit 33df0df948
1 changed files with 14 additions and 0 deletions

14
requests_copy.go
View file

@ -503,8 +503,12 @@ func copySrcSubProcFunc(proc process, cia copyInitialData, cancel context.Cancel
ReplyMethod: REQNone,
Data: csaSerialized,
IsSubPublishedMsg: true,
ACKTimeout: initialMessage.ACKTimeout,
Retries: initialMessage.Retries,
}
fmt.Printf(" * DEBUG: ACKTimeout:%v, Retries: %v\n", initialMessage.ACKTimeout, initialMessage.Retries)
sam, err := newSubjectAndMessage(msg)
if err != nil {
er := fmt.Errorf("copySrcProcSubFunc: newSubjectAndMessage failed: %v", err)
@ -569,6 +573,8 @@ func copySrcSubProcFunc(proc process, cia copyInitialData, cancel context.Cancel
ReplyMethod: REQNone,
Data: csaSerialized,
IsSubPublishedMsg: true,
ACKTimeout: initialMessage.ACKTimeout,
Retries: initialMessage.Retries,
}
sam, err := newSubjectAndMessage(msg)
@ -628,6 +634,8 @@ func copyDstSubProcFunc(proc process, cia copyInitialData, message Message, canc
ReplyMethod: REQNone,
Data: csaSerialized,
IsSubPublishedMsg: true,
ACKTimeout: message.ACKTimeout,
Retries: message.Retries,
}
sam, err := newSubjectAndMessage(msg)
@ -718,6 +726,8 @@ func copyDstSubProcFunc(proc process, cia copyInitialData, message Message, canc
ReplyMethod: REQNone,
Data: csaSer,
IsSubPublishedMsg: true,
ACKTimeout: message.ACKTimeout,
Retries: message.Retries,
}
sam, err := newSubjectAndMessage(msg)
@ -747,6 +757,8 @@ func copyDstSubProcFunc(proc process, cia copyInitialData, message Message, canc
ReplyMethod: REQNone,
Data: csaSer,
IsSubPublishedMsg: true,
ACKTimeout: message.ACKTimeout,
Retries: message.Retries,
}
sam, err := newSubjectAndMessage(msg)
@ -899,6 +911,8 @@ func copyDstSubProcFunc(proc process, cia copyInitialData, message Message, canc
ReplyMethod: REQNone,
Data: csaSerialized,
IsSubPublishedMsg: true,
ACKTimeout: message.ACKTimeout,
Retries: message.Retries,
}
sam, err := newSubjectAndMessage(msg)