rabbitmq

Documentation

Index

• type Client
  • func New(url string) (*Client, error)
  • func (c *Client) NewRoundRobinChannel() (*amqp.Channel, error)

Types

type Client

type Client struct {
	*amqp.Connection
}

func New

func New(url string) (*Client, error)

func (*Client) NewRoundRobinChannel

func (c *Client) NewRoundRobinChannel() (*amqp.Channel, error)

NewRoundRobinChannel creates a consumer channel to be uses in a round-robin fashion model. Consumers must have ack enabled.