code: func (ac *AMQPConnector) Open(url string, tlsConfig *tls.Config) (*amqp.Connection, *amqp.Channel, error) {
  	// Connect
  	// From amqp docs: DialTLS will use the provided tls.Config when it encounters an amqps:// scheme
  	// and will dial a plain connection when it encounters an amqp:// scheme.
  	conn, err := amqp.DialTLS(url, tlsConfig)
  	if err != nil {
  		return nil, nil, fmt.Errorf("Dial error: %s", err)
  	}
  
  	// Open a channel
  	channel, err := conn.Channel()
  	if err != nil {
  		return nil, nil, fmt.Errorf("Open channel error: %s", err)
  	}
  
  	return conn, channel, nil
  }
docs: // Open new RabbitMQ connection