Skip to content

Commit

Permalink
chore: fix lint
Browse files Browse the repository at this point in the history
  • Loading branch information
dilaragorum committed Mar 28, 2024
1 parent 9235292 commit 532d1a4
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions batch_consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -42,9 +42,7 @@ func newBatchConsumer(cfg *ConsumerConfig) (Consumer, error) {
}

if cfg.RetryEnabled {
c.base.setupCronsumer(cfg, func(message kcronsumer.Message) error {
return c.runKonsumerFn(message)
})
c.base.setupCronsumer(cfg, c.runKonsumerFn)
}

if cfg.APIEnabled {
Expand Down

0 comments on commit 532d1a4

Please sign in to comment.