C#•11mo ago

System.UriFormatException: 'Invalid URI: The hostname could not be parsed.'

using RabbitMQ.Client;
using System;

namespace RabbitMQ.Implementations
{
    public abstract class RabbitMQClient : IDisposable
    {
        protected IConnection _connection;
        protected IModel _channel;

        public RabbitMQClient()
        {
            var username = Environment.GetEnvironmentVariable("AMQP_USERNAME") ?? throw new Exception("Env var AMQP_USERNAME is not defined.");
            var password = Environment.GetEnvironmentVariable("AMQP_PASSWORD") ?? throw new Exception("Env var AMQP_PASSWORD is not defined.");
            var host = Environment.GetEnvironmentVariable("AMQP_HOST") ?? throw new Exception("Env var AMQP_HOST is not defined.");

            var factory = new ConnectionFactory
            {
                Uri = new Uri($"amqp://{username}:{password}@{host}")
            };

            _connection = factory.CreateConnection();
            _channel = _connection.CreateModel();
        }

        public void Dispose()
        {
            _connection.Dispose();
            _channel.Dispose();
        }
    }
}

using RabbitMQ.Client;
using System;

namespace RabbitMQ.Implementations
{
    public abstract class RabbitMQClient : IDisposable
    {
        protected IConnection _connection;
        protected IModel _channel;

        public RabbitMQClient()
        {
            var username = Environment.GetEnvironmentVariable("AMQP_USERNAME") ?? throw new Exception("Env var AMQP_USERNAME is not defined.");
            var password = Environment.GetEnvironmentVariable("AMQP_PASSWORD") ?? throw new Exception("Env var AMQP_PASSWORD is not defined.");
            var host = Environment.GetEnvironmentVariable("AMQP_HOST") ?? throw new Exception("Env var AMQP_HOST is not defined.");

            var factory = new ConnectionFactory
            {
                Uri = new Uri($"amqp://{username}:{password}@{host}")
            };

            _connection = factory.CreateConnection();
            _channel = _connection.CreateModel();
        }

        public void Dispose()
        {
            _connection.Dispose();
            _channel.Dispose();
        }
    }
}

18 Replies

Pobiega•11mo ago

And what are your values for those three variables?

HAHAOP•11mo ago

Let me get them I haven't added a try/catch

Pobiega•11mo ago

Don't need one, just set a breakpoint and use the debugger?

HAHAOP•11mo ago

ok host "10.8.3.85" string

HAHAOP•11mo ago

here in the env variables

Pobiega•11mo ago

ah I think the @ fucks you over since your string becomes root:Admin@[email protected]

HAHAOP•11mo ago

might be the case

Pobiega•11mo ago

you'll need to escape it I guess, or change the password

HAHAOP•11mo ago

   Uri = new Uri(@"amqp:/{username}:{password}@{host}")

   Uri = new Uri(@"amqp:/{username}:{password}@{host}")

went for this instead minor case of interpolation

Pobiega•11mo ago

hm will that work thou? no interpolation there that string will become literally amqp:/{username}:{password}@{host}

HAHAOP•11mo ago

yeah just noticed that I meant to write that as it is

  Uri = new Uri("amqp://root:Admin@[email protected]")

  Uri = new Uri("amqp://root:Admin@[email protected]")

Pobiega•11mo ago

not sure that will work either thou having 2 @ in that string will be problematic

HAHAOP•11mo ago

var encodedPassword = Uri.EscapeUriString(password);
var factory = new ConnectionFactory
{
    Uri = new Uri($"amqp://{username}:{encodedPassword}@{host}")
};

var encodedPassword = Uri.EscapeUriString(password);
var factory = new ConnectionFactory
{
    Uri = new Uri($"amqp://{username}:{encodedPassword}@{host}")
};

did this

Pobiega•11mo ago

yep, thats better

HAHAOP•11mo ago

didnt work

Pobiega•11mo ago

rip remove the @ from the password, or find an alternative to using a uri if escaping it wont work

HAHAOP•11mo ago

that was it it worked for test env thxowo

Gaming

Programming

System.UriFormatException: 'Invalid URI: The hostname could not be parsed.'