Versions in this module Expand all Collapse all v0 v0.1.0 Aug 17, 2026 Changes in this version + type Broker struct + func New(cfg Config) (*Broker, error) + func (b *Broker) Bind(queue, exchange, routingKey string) error + func (b *Broker) Close() error + func (b *Broker) Connect() error + func (b *Broker) Consumer(destination string, opts mq.ConsumeOptions) (mq.Consumer, error) + func (b *Broker) DeclareExchange(name string, opts mq.ExchangeOptions) error + func (b *Broker) DeclareQueue(name string, opts mq.QueueOptions) error + func (b *Broker) DeleteExchange(name string) error + func (b *Broker) DeleteQueue(name string) error + func (b *Broker) IsConnected() bool + func (b *Broker) Metrics() mq.Metrics + func (b *Broker) Producer(destination string, opts mq.PublishOptions) (mq.Producer, error) + func (b *Broker) Unbind(queue, exchange, routingKey string) error + type Config struct + Addr string + ConnectTimeout time.Duration + Heartbeat time.Duration + Login string + Network string + Passcode string + Vhost string + func DefaultConfig() Config + type Consumer struct + func (c *Consumer) IsRunning() bool + func (c *Consumer) Start(ctx context.Context) error + func (c *Consumer) Stop(timeout time.Duration) error + type Producer struct + func (p *Producer) Close() error + func (p *Producer) Publish(ctx context.Context, msg *mq.Message) error
Go to main page