rabbitmq

Documentation

Index

• Constants
• func WithConsumerRoutingKeys(routingKeys ...string) func(c *Client)
• func WithExchangeName(exchangeName string) func(c *Client)
• func WithExchangeType(exchangeType string) func(c *Client)
• func WithHost(host string) func(c *Client)
• func WithPassword(password string) func(c *Client)
• func WithPort(port uint) func(c *Client)
• func WithQueueName(queueName string) func(c *Client)
• func WithUser(user string) func(c *Client)
• type Acknowledger
  • func NewAcknowledger(delivery amqp091.Delivery) *Acknowledger
  • func (a *Acknowledger) Ack() error
  • func (a *Acknowledger) Nack(opts messages.NackOpts) error
• type Client
  • func NewClient(opts ...ConsumerOpt) (*Client, error)
  • func (r *Client) Close() error
  • func (r *Client) Consume() (<-chan messages.Message, error)
  • func (r *Client) Publish(ctx context.Context, eventData events.EventData, ...) error
  • func (r *Client) QueueName() string
• type ConsumerOpt

Constants

const (
	DefaultHost     = "localhost"
	DefaultPort     = 5672
	DefaultUser     = "guest"
	DefaultPassword = "guest"

	ManagementUIPort = 15672

	ExchangeTypeDirect = "direct"
	ExchangeTypeTopic  = "topic"
	ExchangeTypeFanout = "fanout"
)

Functions

func WithConsumerRoutingKeys

func WithConsumerRoutingKeys(routingKeys ...string) func(c *Client)

func WithExchangeName

func WithExchangeName(exchangeName string) func(c *Client)

func WithExchangeType

func WithExchangeType(exchangeType string) func(c *Client)

func WithHost

func WithHost(host string) func(c *Client)

func WithPassword

func WithPassword(password string) func(c *Client)

func WithPort

func WithPort(port uint) func(c *Client)

func WithQueueName

func WithQueueName(queueName string) func(c *Client)

func WithUser

func WithUser(user string) func(c *Client)

Types

type Acknowledger

type Acknowledger struct {
	// contains filtered or unexported fields
}

func NewAcknowledger

func NewAcknowledger(delivery amqp091.Delivery) *Acknowledger

func (*Acknowledger) Ack

func (a *Acknowledger) Ack() error

func (*Acknowledger) Nack

func (a *Acknowledger) Nack(opts messages.NackOpts) error

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(opts ...ConsumerOpt) (*Client, error)

func (*Client) Close

func (r *Client) Close() error

func (*Client) Consume

func (r *Client) Consume() (<-chan messages.Message, error)

func (*Client) Publish

func (r *Client) Publish(ctx context.Context, eventData events.EventData, routingInfo events.RoutingInfo) error

TODO Move out of the client to a dedicated Publisher

func (*Client) QueueName

func (r *Client) QueueName() string

type ConsumerOpt

type ConsumerOpt func(consumer *Client)