rabbitclient

Documentation

Index

• type Client
  • func New(connStr string) *Client
  • func (c *Client) Close()
  • func (c *Client) Connect()
  • func (c *Client) Consume(queueName string, callback func(amqp091.Delivery) error) error
  • func (c *Client) Publish(queueName string, body string) error
• type Config
  • func (cfg *Config) String() string

Types

type Client

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

func New

func New(connStr string) *Client

func (*Client) Close

func (c *Client) Close()

func (*Client) Connect

func (c *Client) Connect()

func (*Client) Consume

func (c *Client) Consume(queueName string, callback func(amqp091.Delivery) error) error

func (*Client) Publish

func (c *Client) Publish(queueName string, body string) error

type Config

type Config struct {
	User string
	Pass string
	Host string
	Port string
}

func (*Config) String

func (cfg *Config) String() string