amqpextra

Feb 16, 2021

Changes in this version

type Config

+ ConnectionTimeout time.Duration

+ InitTimeout time.Duration

Aug 24, 2020

Changes in this version

+ type Config struct

+ Connection ConnectionConfig

+ Exchange string

+ Logger *log.Logger

+ Prefetch int

+ Queue string

+ ReconnectionTimeout time.Duration

+ RoutingKey string

+ type ConnectionConfig struct

+ Host string

+ Password string

+ Port int

+ User string

+ VirtualHost string

+ func (c *ConnectionConfig) Raw() string

+ func (c *ConnectionConfig) String() string

+ type Worker struct

+ func New(c Config) (*Worker, error)

+ func (w *Worker) Close() error

+ func (w *Worker) Publish(ctx context.Context, message broker.Publishable) error

+ func (w *Worker) StartConsumer(handlers map[string]func([]byte) error, ...) error