amqphandler

Dec 20, 2023

Changes in this version

type Config

+ InactiveTimeout time.Duration

Aug 26, 2023

Changes in this version

type Config

+ Exchange string

+ Exclusive bool

+ MaxRetry uint

+ Queue string

+ RetryInterval time.Duration

+ RoutingKey string

+ type Service struct

+ func (a *Service) Done() <-chan struct{}

+ func (a *Service) Start(ctx context.Context)

+ func (a Service) Retry(message amqp.Delivery) error

Aug 25, 2022

Changes in this version

+ type Handler func(context.Context, amqp.Delivery) error

Nov 13, 2021

Changes in this version

+ var ErrNoDeathCount = errors.New("no death count")

+ func GetDeathCount(message amqp.Delivery) (int64, error)

+ type App struct

+ func New(config Config, amqpClient *amqpclient.Client, ...) (App, error)

+ func NewFromString(amqpClient *amqpclient.Client, handler func(amqp.Delivery) error, ...) (App, error)

+ func (a App) Done() <-chan struct{}

+ func (a App) Enabled() bool

+ func (a App) Retry(message amqp.Delivery) error

+ func (a App) Start(done <-chan struct{})

+ type Config struct

+ func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) Config