Skip to content

Commit

Permalink
fix the build (#1449)
Browse files Browse the repository at this point in the history
  • Loading branch information
tmasternak authored Oct 16, 2024
1 parent 02498e7 commit 5384574
Showing 1 changed file with 10 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@
using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Data.SqlClient;
using NUnit.Framework;
using Transport;
using Transport.SqlServer;
Expand Down Expand Up @@ -45,15 +46,15 @@ public async Task Peeker_should_provide_accurate_queue_length_estimate(Transport
Assert.That(peekCount, Is.EqualTo(1), "A long running receive transaction should not skew the estimation for number of messages in the queue.");
}

static async Task<SqlTableBasedQueue> CreateATestQueue(SqlServerDbConnectionFactory connectionFactory, CancellationToken cancellationToken)
async Task<SqlTableBasedQueue> CreateATestQueue(SqlServerDbConnectionFactory connectionFactory, CancellationToken cancellationToken)
{
var queueName = "queue_length_estimation_test";

var sqlConstants = new SqlServerConstants();

var queue = new SqlTableBasedQueue(sqlConstants, queueName, queueName, false);
var queue = new SqlTableBasedQueue(sqlConstants, new CanonicalQueueAddress(queueName, "dbo", catalogName), queueName, false);

var addressTranslator = new QueueAddressTranslator("nservicebus", "dbo", null, null);
var addressTranslator = new QueueAddressTranslator(catalogName, "dbo", null, null);
var queueCreator = new QueueCreator(sqlConstants, connectionFactory, addressTranslator.Parse, false);

await queueCreator.CreateQueueIfNecessary(new[] { queueName }, null, cancellationToken);
Expand Down Expand Up @@ -100,6 +101,10 @@ await queue.Send(
[SetUp]
public async Task Setup()
{
var connectionString = ConfigureSqlServerTransportInfrastructure.ConnectionString;
var connectionStringBuilder = new SqlConnectionStringBuilder(connectionString);

catalogName = connectionStringBuilder.InitialCatalog;
connectionFactory = new SqlServerDbConnectionFactory(ConfigureSqlServerTransportInfrastructure.ConnectionString);

queue = await CreateATestQueue(connectionFactory, CancellationToken.None);
Expand All @@ -121,6 +126,8 @@ public async Task TearDown()
await comm.ExecuteNonQueryAsync(CancellationToken.None);
}

string catalogName;

SqlTableBasedQueue queue;
SqlServerDbConnectionFactory connectionFactory;
}

0 comments on commit 5384574

Please sign in to comment.