Documentation ¶ Index ¶ type Client func New(config Config, connect *amqp.Connection) (*Client, error) func (c *Client) Close() func (c *Client) Open() (err error) func (c *Client) Publish(msg amqp.Publishing) error type Config func NewConfig(hosts, queue string, bind bool, args amqp.Table) Config 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 New ¶ func New(config Config, connect *amqp.Connection) (*Client, error) func (*Client) Close ¶ func (c *Client) Close() func (*Client) Open ¶ added in v0.1.2 func (c *Client) Open() (err error) func (*Client) Publish ¶ added in v0.1.2 func (c *Client) Publish(msg amqp.Publishing) error type Config ¶ added in v0.1.2 type Config struct { // contains filtered or unexported fields } func NewConfig ¶ added in v0.1.2 func NewConfig(hosts, queue string, bind bool, args amqp.Table) Config Source Files ¶ View all Source files client.go Click to show internal directories. Click to hide internal directories.