amqp

Nov 29, 2023

Changes in this version

+ type PublisherOption func(options *publisherOptions)

+ func WithAutoMessageID() PublisherOption

+ func WithAutoTimestamp() PublisherOption

Nov 28, 2023

Changes in this version

type RabbitMQOptions

+ func WithCustomEncoder(encType types.EncodeType) RabbitMQOptions

Nov 28, 2023

Changes in this version

type RabbitMQOptions

+ func WithCustomLogger(logger logger.Logger) RabbitMQOptions

Nov 27, 2023

Changes in this version

+ var ErrChannelIsNotCreated = errors.New("channel is not created, please check your connection or wait")

+ var ErrConsumerIsNil = errors.New("consumer is nil")

+ var ErrExchangeIsNil = errors.New("exchange is nil")

+ var ErrQueueIsNil = errors.New("queue is nil")

+ var ErrRoutingKeyIsNil = errors.New("routing key is nil")

+ type AMQP struct

+ func (r *AMQP) Close() error

+ func (r *AMQP) Consumer(exchange *types.Exchange, queue *types.Queue, consume *types.Consumer, ...) (Consumer, error)

+ func (r *AMQP) Publisher(exchange *types.Exchange, logger logger.Logger, confirmMode bool) (Publisher, error)

+ type Broker interface

+ Close func() error

+ Consumer func(exchange *types.Exchange, queue *types.Queue, consumer *types.Consumer, ...) (Consumer, error)

+ Publisher func(exchange *types.Exchange, logger logger.Logger, confirmMode bool) (Publisher, error)

+ func New(url string, logger logger.Logger, options ...RabbitMQOptions) (Broker, error)

+ type Consumer interface

+ Close func()

+ Start func() error

+ type ConsumerOptions func(options *consumerOptions)

+ func EnableQOSGlobal(enable bool) ConsumerOptions

+ func WithConcurrentConsumer(concurrent int) ConsumerOptions

+ func WithCustomQOSPrefetch(prefetch int) ConsumerOptions

+ type Publisher interface

+ Close func()

+ NotifyPublish func(handler func(p types.Confirmation))

+ NotifyReturn func(handler func(r types.Return))

+ Publish func(mandatory bool, immediate bool, msg types.Publishing, routingKeys ...string) error

+ PublishWithContext func(ctx context.Context, mandatory bool, immediate bool, msg types.Publishing, ...) error

+ PublishWithDeferredConfirmWithContext func(ctx context.Context, mandatory bool, immediate bool, msg types.Publishing, ...) (types.PublisherConfirmation, error)

+ PublishWithRetry func(ctx context.Context, mandatory bool, immediate bool, msg types.Publishing, ...) error

+ type RabbitMQOptions func(*rabbitMQOptions)

+ func ReconnectDelay(delay time.Duration) RabbitMQOptions

+ func WithCustomAMQPConfig(config amqp.Config) RabbitMQOptions