Method connection

client.go:222–229

()

}

func (c *Client) connection() (*amqp.Connection, error) {
	conn, _ := c.conn.Load().(*amqp.Connection)
	if conn == nil {
		return nil, ErrNoConnection
	}

	return conn, nil
}

// NewClient initializes new Client
func NewClient(opts ...ClientOpt) *Client {