code: func (ai *Amqp) Close() error {
  	if err := ai.ch.Close(); err != nil {
  		return err
  	}
  
  	if ai.conn != nil {
  		return ai.conn.Close()
  	}
  
  	return nil
  }
docs: // Close closes the running amqp connection and channel