code: func New(dsn string, pex bool) (*Amqp, error) {
  	conn, ch, err := createConnAndChan(dsn)
  	if err != nil {
  		return nil, err
  	}
  
  	return &Amqp{
  		conn:            conn,
  		ch:              ch,
  		passiveExchange: pex,
  	}, nil
  }
docs: // New returns a new Amqp configured, or returning an non-nil err
  // if an error occurred while creating connection or channel.