repeated consumption by multiple subscribers about watermill

[roblaszczak]

Hello @pnpdb, it depends on subscriber implementation :)

• For Kafka, it depends on the consumer group
• For Google Cloud Pub/Sub it depends on subscription name (you can pass how to generate it to Pub/Sub constructor config)
• For RabbitMQ it depends if you are using queue or pub/sub
• ... etc ;)

After you will provide a context which implementation are you using, I can probably help more :)

[pnpdb]

thank you very much, i have another question, for rabbitmq, how to use pull mod ? for example, i want to pull 100 messages once.

[m110]

Hey @pnpdb, you're probably looking for QosConfig.PrefetchCount: https://github.com/ThreeDotsLabs/watermill-amqp/blob/master/pkg/amqp/config.go#L449

[roblaszczak]

@pnpdb I hope that that answered your question?

Also, the BulkRead function may be useful:

watermill/message/subscriber/read.go

Line 10 in 63b5247

func BulkRead(messagesCh <-chan *message.Message, limit int, timeout time.Duration) (receivedMessages message.Messages, all bool) {

// BulkRead reads provided amount of messages from the provided channel, until a timeout occurrs or the limit is reached.
func BulkRead(messagesCh <-chan *message.Message, limit int, timeout time.Duration) (receivedMessages message.Messages, all bool) {

I'm closing the issue because all the questions seem to be answered :)