grmqt

Documentation

Index

• type Client
  • func New(t *test.Test) *Client
  • func (c *Client) ConnectionConfig() grmqx.Connection
  • func (c *Client) DrainMessage(queue string) amqp091.Delivery
  • func (c *Client) Publish(exchange string, routingKey string, messages ...amqp091.Publishing)
  • func (c *Client) PublishJson(exchange string, routingKey string, data any)
  • func (c *Client) QueueLength(queue string) int
  • func (c *Client) Upgrade(config grmqx.Config)

Types

type Client

type Client struct {
	GrmqxCli *grmqx.Client
	// contains filtered or unexported fields
}

func New

func New(t *test.Test) *Client

func (*Client) ConnectionConfig

func (c *Client) ConnectionConfig() grmqx.Connection

func (*Client) DrainMessage

func (c *Client) DrainMessage(queue string) amqp091.Delivery

func (*Client) Publish

func (c *Client) Publish(exchange string, routingKey string, messages ...amqp091.Publishing)

func (*Client) PublishJson

func (c *Client) PublishJson(exchange string, routingKey string, data any)

func (*Client) QueueLength

func (c *Client) QueueLength(queue string) int

func (*Client) Upgrade

func (c *Client) Upgrade(config grmqx.Config)