Parallel consumers from 1 queue

[maciejbak85]

Is there an option to run multiple consumers from 1 queue ?
( Or it can be achieved only by running multiple streams from 1 queue and set proper VisibilityTimeout to avoid duplicates. )

thanks!

[ghostdogpr]

Sure, the API gives you a ZIO Stream, you can use some of the parallel stream combinators like mapMPar to have multiple consumers.

[maciejbak85]

sqsService.consumeRequests().mapMParUnordered(4)(processBaseOnType).runDrain

ok cool thanks