Skip to content

Commit

Permalink
cleaned up
Browse files Browse the repository at this point in the history
  • Loading branch information
mookid8000 committed Aug 24, 2016
1 parent efcd07c commit cdb8c6d
Show file tree
Hide file tree
Showing 3 changed files with 41 additions and 27 deletions.
28 changes: 1 addition & 27 deletions Rebus.AzureServiceBus.Tests/AzureServiceBusDoNotCreateQueue.cs
Expand Up @@ -13,6 +13,7 @@
using Rebus.Tests.Extensions;
using Rebus.Threading.TaskParallelLibrary;
using Rebus.Transport;
#pragma warning disable 1998

namespace Rebus.AzureServiceBus.Tests
{
Expand Down Expand Up @@ -188,31 +189,4 @@ public async void ShouldBeAbleToRecieveEvenWhenNotCreatingQueue(AzureServiceBusM

}
}

public class NotCreatingQueueTest : FixtureBase
{
[TestCase(AzureServiceBusMode.Basic)]
[TestCase(AzureServiceBusMode.Standard)]
public void ShouldNotCreateInputQueueWhenConfiguredNotTo(AzureServiceBusMode mode)
{
var manager = NamespaceManager.CreateFromConnectionString(StandardAzureServiceBusTransportFactory.ConnectionString);
var queueName = Guid.NewGuid().ToString("N");

Assert.IsFalse(manager.QueueExists(queueName));

var recieverActivator = new BuiltinHandlerActivator();
var bus = Configure.With(recieverActivator)
.Logging(l => l.ColoredConsole())
.Transport(t =>
t.UseAzureServiceBus(StandardAzureServiceBusTransportFactory.ConnectionString, queueName, mode)
.DoNotCreateQueues())
.Start();

Assert.IsFalse(manager.QueueExists(queueName));

Using(recieverActivator);
Using(bus);

}
}
}
39 changes: 39 additions & 0 deletions Rebus.AzureServiceBus.Tests/NotCreatingQueueTest.cs
@@ -0,0 +1,39 @@
using System;
using Microsoft.ServiceBus;
using NUnit.Framework;
using Rebus.Activation;
using Rebus.AzureServiceBus.Config;
using Rebus.AzureServiceBus.Tests.Factories;
using Rebus.Config;
using Rebus.Tests;

namespace Rebus.AzureServiceBus.Tests
{
[TestFixture]
public class NotCreatingQueueTest : FixtureBase
{
[TestCase(AzureServiceBusMode.Basic)]
[TestCase(AzureServiceBusMode.Standard)]
public void ShouldNotCreateInputQueueWhenConfiguredNotTo(AzureServiceBusMode mode)
{
var connectionString = StandardAzureServiceBusTransportFactory.ConnectionString;
var manager = NamespaceManager.CreateFromConnectionString(connectionString);
var queueName = Guid.NewGuid().ToString("N");

Assert.IsFalse(manager.QueueExists(queueName));

var activator = Using(new BuiltinHandlerActivator());

Configure.With(activator)
.Logging(l => l.ColoredConsole())
.Transport(t =>
{
t.UseAzureServiceBus(connectionString, queueName, mode)
.DoNotCreateQueues();
})
.Start();

Assert.IsFalse(manager.QueueExists(queueName));
}
}
}
Expand Up @@ -80,6 +80,7 @@
<Compile Include="Factories\StandardAzureServiceBusTransportFactory.cs" />
<Compile Include="FailsWhenSendingToNonExistentQueue.cs" />
<Compile Include="NativeDeferTest.cs" />
<Compile Include="NotCreatingQueueTest.cs" />
<Compile Include="TestAsbTopicsPubSub.cs" />
<Compile Include="TestCategory.cs" />
<Compile Include="TestShutdownTime.cs" />
Expand Down

0 comments on commit cdb8c6d

Please sign in to comment.