iface

Feb 7, 2022

Changes in this version

type Broker

+ GetDelayedTasks func() ([]*tasks.Signature, error)

type TaskProcessor

+ PreConsumeHandler func() bool

Aug 4, 2018

Changes in this version

type TaskProcessor

+ CustomQueue func() string

Jul 12, 2018

Changes in this version

+ type Broker interface

+ AdjustRoutingKey func(s *tasks.Signature)

+ GetConfig func() *config.Config

+ GetPendingTasks func(queue string) ([]*tasks.Signature, error)

+ IsTaskRegistered func(name string) bool

+ Publish func(task *tasks.Signature) error

+ SetRegisteredTaskNames func(names []string)

+ StartConsuming func(consumerTag string, concurrency int, p TaskProcessor) (bool, error)

+ StopConsuming func()

+ type TaskProcessor interface

+ Process func(signature *tasks.Signature) error