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 WithPort(port uint) func(c *Client)
• func WithQueueName(queueName string) func(c *Client)
• 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, message []byte, routingKey string) error
  • func (r *Client) QueueName() string
• type ConsumerOpt

Constants

const (
	DefaultPort      = 5672
	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 WithPort

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

func WithQueueName

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

Types

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, message []byte, routingKey string) error

func (*Client) QueueName

func (r *Client) QueueName() string

type ConsumerOpt

type ConsumerOpt func(consumer *Client)