subscriber

Documentation

Index

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

Functions

func BulkRead

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 occurs or the limit is reached.

func BulkReadWithDeduplication

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

BulkReadWithDeduplication reads provided number of messages from the provided channel, ignoring duplicates, until a timeout occurs or the limit is reached.