Import path: gitlab.soludian.com/soludian/fountain/libs/brokers/subscriber

subscriber

go

import "gitlab.soludian.com/soludian/fountain/libs/brokers/subscriber"

Index

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

func BulkRead

go

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

BulkRead đọc số lượng message được gửi từ kênh, cho đến khi xảy ra timeout hoặc đạt đến giới hạn.

func BulkReadWithDeduplication

go

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

BulkReadWithDeduplication đọc số lượng message được gửi từ kênh, bỏ qua các message trùng lặp, cho đến khi xảy ra timeout hoặc đạt đến giới hạn.

Generated by gomarkdoc