Documentation ¶ Index ¶ type Client func NewClient(uri string) (*Client, error) func (c *Client) GetConn() *amqp.Connection func (c *Client) PublishBody(ex, rk, body string) error type Consumer func NewConsumer(amqpURI, queueName, ctag string, fn func([]byte)) (*Consumer, error) func (c *Consumer) Shutdown() error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Client ¶ type Client struct { // contains filtered or unexported fields } func NewClient ¶ func NewClient(uri string) (*Client, error) func (*Client) GetConn ¶ func (c *Client) GetConn() *amqp.Connection func (*Client) PublishBody ¶ func (c *Client) PublishBody(ex, rk, body string) error type Consumer ¶ type Consumer struct { // contains filtered or unexported fields } func NewConsumer ¶ func NewConsumer(amqpURI, queueName, ctag string, fn func([]byte)) (*Consumer, error) func (*Consumer) Shutdown ¶ func (c *Consumer) Shutdown() error Source Files ¶ View all Source files client.go consumer.go Click to show internal directories. Click to hide internal directories.