Skip to content

Commit

Permalink
Remove --max-in-flight max of 256
Browse files Browse the repository at this point in the history
Async publishing is now smarter
  • Loading branch information
mkuratczyk committed Dec 9, 2024
1 parent 2293768 commit 21615d0
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cmd/root.go
Original file line number Diff line number Diff line change
Expand Up @@ -574,8 +574,8 @@ func sanitizeConfig(cfg *config.Config) error {
return fmt.Errorf("combined release and reject rate can't be more than 100%%")
}

if cfg.MaxInFlight < 1 || cfg.MaxInFlight > 256 {
return fmt.Errorf("max-in-flight must be between 1 and 256")
if cfg.MaxInFlight < 1 {
return fmt.Errorf("max-in-flight must be at least 1")
}

// go-amqp treats `0` as if the value was not set and uses 1 credit
Expand Down

0 comments on commit 21615d0

Please sign in to comment.