Fix validation of subscriber ack deadline (#50)

edebernis · web-flow · commit e46e72f0253c · 2025-06-12T12:24:07.000+02:00
diff --git a/pkg/sql/subscriber.go b/pkg/sql/subscriber.go
@@ -83,7 +83,7 @@ func (c SubscriberConfig) validate() error {
 	if c.AckDeadline == nil {
 		return errors.New("ack deadline is nil")
 	}
-	if c.AckDeadline != nil && *c.AckDeadline <= 0 {
+	if c.AckDeadline != nil && *c.AckDeadline < 0 {
 		return errors.New("ack deadline must be a positive duration")
 	}
 	if c.PollInterval <= 0 {

Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,7 @@ func (c SubscriberConfig) validate() error {`
`83`	`83`	`if c.AckDeadline == nil {`
`84`	`84`	`return errors.New("ack deadline is nil")`
`85`	`85`	`}`
`86`		`- if c.AckDeadline != nil && *c.AckDeadline <= 0 {`
	`86`	`+ if c.AckDeadline != nil && *c.AckDeadline < 0 {`
`87`	`87`	`return errors.New("ack deadline must be a positive duration")`
`88`	`88`	`}`
`89`	`89`	`if c.PollInterval <= 0 {`