diff options
| -rw-r--r-- | dotnet/Qpid.Client.Tests/Common/BaseMessagingTestFixture.cs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/dotnet/Qpid.Client.Tests/Common/BaseMessagingTestFixture.cs b/dotnet/Qpid.Client.Tests/Common/BaseMessagingTestFixture.cs index a5085ee199..e27174909c 100644 --- a/dotnet/Qpid.Client.Tests/Common/BaseMessagingTestFixture.cs +++ b/dotnet/Qpid.Client.Tests/Common/BaseMessagingTestFixture.cs @@ -22,6 +22,7 @@ using System; using log4net; using NUnit.Framework; using Qpid.Messaging; +using Qpid.Client.qms; namespace Qpid.Client.Tests { @@ -29,6 +30,8 @@ namespace Qpid.Client.Tests { private static ILog _logger = LogManager.GetLogger(typeof(BaseMessagingTestFixture)); + const string connectionUri = "amqp://guest:guest@default/test?brokerlist='tcp://localhost:5672'"; + protected IConnection _connection; protected IChannel _channel; @@ -38,9 +41,7 @@ namespace Qpid.Client.Tests { try { - QpidConnectionInfo connectionInfo = new QpidConnectionInfo(); - - connectionInfo.AddBrokerInfo(new AmqBrokerInfo("amqp", "localhost", 5672, false)); + ConnectionInfo connectionInfo = QpidConnectionInfo.FromUrl(connectionUri); _connection = new AMQConnection(connectionInfo); _channel = _connection.CreateChannel(false, AcknowledgeMode.NoAcknowledge, 1); } |