consume

Nov 30, 2024

Changes in this version

type Option

+ func WithStartReadDelay(value time.Duration) Option

Nov 16, 2024

Changes in this version

type MessageProcessor

+ func (p *MessageProcessor) ReadyTimeout() time.Duration

type Option

+ func WithBusyReadPeriod(value time.Duration) Option

+ func WithCancelReadTimeout(value time.Duration) Option

+ func WithHandlerTimeout(value time.Duration) Option

+ func WithReadPeriod(value time.Duration) Option

+ func WithReadyTimeout(value time.Duration) Option

Oct 27, 2024

Changes in this version

+ type MessageProcessor struct

+ func NewMessageProcessor(consumer mrworker.MessageConsumer, handler mrworker.MessageHandler, ...) *MessageProcessor

+ func (p *MessageProcessor) Caption() string

+ func (p *MessageProcessor) Shutdown(_ context.Context) error

+ func (p *MessageProcessor) Start(ctx context.Context, ready func()) error

+ type Option func(p *MessageProcessor)

+ func WithCaption(value string) Option

+ func WithPeriod(value time.Duration) Option

+ func WithQueueSize(value uint32) Option

+ func WithTimeout(value time.Duration) Option

+ func WithWorkersCount(value uint16) Option