mq

Documentation

Index

• type Client
  • func New(cfg *Config) Client
  • func (c *Client) Close() error
  • func (c *Client) Connect() error
  • func (c *Client) PublishJSONMessage(qName string, msgId string, body []byte) error
  • func (c *Client) PublishMessage(qName string, msgId string, appId string, userId string, mimeType string, ...) error
  • func (c *Client) PublishTextMessage(qName string, msgId string, body []byte) error
  • func (c *Client) QueueDeclare(name string) (*amqp.Queue, error)
• type Config

Types

type Client

type Client struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
	// contains filtered or unexported fields
}

func New

func New(cfg *Config) Client

func (*Client) Close

func (c *Client) Close() error

func (*Client) Connect

func (c *Client) Connect() error

func (*Client) PublishJSONMessage

func (c *Client) PublishJSONMessage(qName string, msgId string, body []byte) error

func (*Client) PublishMessage

func (c *Client) PublishMessage(qName string, msgId string, appId string, userId string, mimeType string, body []byte) error

func (*Client) PublishTextMessage

func (c *Client) PublishTextMessage(qName string, msgId string, body []byte) error

func (*Client) QueueDeclare

func (c *Client) QueueDeclare(name string) (*amqp.Queue, error)

type Config

type Config struct {
	Host        string
	Port        string
	Username    string
	Password    string
	VirtualHost string
	Exchange    string
}