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

allowing retries=0

Browse source
This commit is contained in:
postmannen 2023-04-26 07:25:14 +02:00
parent 7e9754fcdd
commit 11b6cb6a0e
1 changed files with 3 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
ringbuffer.go
View file

@ -177,8 +177,8 @@ func (r *ringBuffer) fillBuffer(ctx context.Context, inCh chan subjectAndMessage
sam.Subject.Event = EventNACK
}
// TODO: Make so 0 is an usable option for retries.
if sam.Message.Retries < 1 {
switch {
case sam.Message.Retries < 0:
sam.Message.Retries = r.configuration.DefaultMessageRetries
}
if sam.Message.MethodTimeout < 1 && sam.Message.MethodTimeout != -1 {
@ -281,9 +281,6 @@ func (r *ringBuffer) processBufferMessages(ctx context.Context, outCh chan samDB
},
}
// ticker := time.NewTicker(time.Duration(v.SAM.ACKTimeout) * time.Duration(v.SAM.Retries) * 2 * time.Second)
// defer ticker.Stop()
outCh <- sd
// Just to confirm here that the message was picked up, to know if the
// the read process have stalled or not.
@ -303,7 +300,7 @@ func (r *ringBuffer) processBufferMessages(ctx context.Context, outCh chan samDB
// message will be able to signal back here that the message have
// been processed, and that we then can delete it out of the K/V Store.
// The publisAMessage method should send a done back here, but in some situations
// The publishAMessage method should send a done back here, but in some situations
// it seems that that do not happen. Implementing a ticker that is twice the total
// amount of time a message should be allowed to be using for getting published so
// we don't get stuck go routines here.