Grouped all base tests at the top of the test file.

NuGet.config

@@ -1,6 +1,6 @@
-<?xml version="1.0" encoding="UTF-8"?>	
-<configuration>	
-    <packageSources>	
-        <add key="Foundatio" value="https://f.feedz.io/foundatio/foundatio/nuget/index.json" />	
-    </packageSources>	
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration>
+    <packageSources>
+        <add key="Foundatio" value="https://f.feedz.io/foundatio/foundatio/nuget/index.json" />
+    </packageSources>
 </configuration>

src/Foundatio.TestHarness/Storage/FileStorageTestsBase.cs

@@ -514,7 +514,6 @@ public virtual async Task WillRespectStreamOffsetAsync()
 
     public virtual async Task WillWriteStreamContentAsync()
     {
-
         const string testContent = "test";
         const string path = "created.txt";
 

tests/Foundatio.Tests/Jobs/InMemoryJobQueueTests.cs

@@ -1,8 +1,6 @@
 using System;
 using System.Threading.Tasks;
-using Foundatio.Caching;
 using Foundatio.Queues;
-using Microsoft.Extensions.Logging;
 
 using Xunit;
 using Xunit.Abstractions;
@@ -27,8 +25,6 @@ public override Task CanRunMultipleQueueJobsAsync()
     [Fact]
     public override Task CanRunQueueJobWithLockFailAsync()
     {
-        Log.SetLogLevel<InMemoryCacheClient>(LogLevel.Trace);
-
         return base.CanRunQueueJobWithLockFailAsync();
     }
 

tests/Foundatio.Tests/Messaging/InMemoryMessageBusTests.cs

@@ -34,19 +34,6 @@ public override Task CanUseMessageOptionsAsync()
         return base.CanUseMessageOptionsAsync();
     }
 
-    [Fact]
-    public async Task CanCheckMessageCounts()
-    {
-        var messageBus = new InMemoryMessageBus(o => o.LoggerFactory(Log));
-        await messageBus.PublishAsync(new SimpleMessageA
-        {
-            Data = "Hello"
-        });
-        Assert.Equal(1, messageBus.MessagesSent);
-        Assert.Equal(1, messageBus.GetMessagesSent<SimpleMessageA>());
-        Assert.Equal(0, messageBus.GetMessagesSent<SimpleMessageB>());
-    }
-
     [Fact]
     public override Task CanSendMessageAsync()
     {
@@ -149,6 +136,19 @@ public override void CanDisposeWithNoSubscribersOrPublishers()
         base.CanDisposeWithNoSubscribersOrPublishers();
     }
 
+    [Fact]
+    public async Task CanCheckMessageCounts()
+    {
+        var messageBus = new InMemoryMessageBus(o => o.LoggerFactory(Log));
+        await messageBus.PublishAsync(new SimpleMessageA
+        {
+            Data = "Hello"
+        });
+        Assert.Equal(1, messageBus.MessagesSent);
+        Assert.Equal(1, messageBus.GetMessagesSent<SimpleMessageA>());
+        Assert.Equal(0, messageBus.GetMessagesSent<SimpleMessageB>());
+    }
+
     public void Dispose()
     {
         _messageBus?.Dispose();

tests/Foundatio.Tests/Queue/InMemoryQueueTests.cs

@@ -46,83 +46,6 @@ protected override async Task CleanupQueueAsync(IQueue<SimpleWorkItem> queue)
         }
     }
 
-    [Fact]
-    public async Task TestAsyncEvents()
-    {
-        using var q = new InMemoryQueue<SimpleWorkItem>(o => o.LoggerFactory(Log));
-        var disposables = new List<IDisposable>(5);
-        try
-        {
-            disposables.Add(q.Enqueuing.AddHandler(async (sender, args) =>
-            {
-                await Task.Delay(250);
-                _logger.LogInformation("First Enqueuing");
-            }));
-            disposables.Add(q.Enqueuing.AddHandler(async (sender, args) =>
-            {
-                await Task.Delay(250);
-                _logger.LogInformation("Second Enqueuing");
-            }));
-            disposables.Add(q.Enqueued.AddHandler(async (sender, args) =>
-            {
-                await Task.Delay(250);
-                _logger.LogInformation("First");
-            }));
-            disposables.Add(q.Enqueued.AddHandler(async (sender, args) =>
-            {
-                await Task.Delay(250);
-                _logger.LogInformation("Second");
-            }));
-
-            var sw = Stopwatch.StartNew();
-            await q.EnqueueAsync(new SimpleWorkItem());
-            sw.Stop();
-            if (_logger.IsEnabled(LogLevel.Trace)) _logger.LogTrace("Time {Elapsed:g}", sw.Elapsed);
-
-            sw.Restart();
-            await q.EnqueueAsync(new SimpleWorkItem());
-            sw.Stop();
-            if (_logger.IsEnabled(LogLevel.Trace)) _logger.LogTrace("Time {Elapsed:g}", sw.Elapsed);
-        }
-        finally
-        {
-            foreach (var disposable in disposables)
-                disposable.Dispose();
-        }
-    }
-
-    [Fact]
-    public async Task CanGetCompletedEntries()
-    {
-        using var q = new InMemoryQueue<SimpleWorkItem>(o => o.LoggerFactory(Log).CompletedEntryRetentionLimit(10));
-
-        await q.EnqueueAsync(new SimpleWorkItem());
-        Assert.Single(q.GetEntries());
-        Assert.Empty(q.GetDequeuedEntries());
-        Assert.Empty(q.GetCompletedEntries());
-
-        var item = await q.DequeueAsync();
-        Assert.Empty(q.GetEntries());
-        Assert.Single(q.GetDequeuedEntries());
-        Assert.Empty(q.GetCompletedEntries());
-
-        await item.CompleteAsync();
-        Assert.Empty(q.GetEntries());
-        Assert.Empty(q.GetDequeuedEntries());
-        Assert.Single(q.GetCompletedEntries());
-
-        for (int i = 0; i < 100; i++)
-        {
-            await q.EnqueueAsync(new SimpleWorkItem());
-            item = await q.DequeueAsync();
-            await item.CompleteAsync();
-        }
-
-        Assert.Empty(q.GetEntries());
-        Assert.Empty(q.GetDequeuedEntries());
-        Assert.Equal(10, q.GetCompletedEntries().Count);
-    }
-
     [Fact]
     public override Task CanQueueAndDequeueWorkItemAsync()
     {
@@ -291,6 +214,83 @@ public override Task CanHandleAutoAbandonInWorker()
         return base.CanHandleAutoAbandonInWorker();
     }
 
+    [Fact]
+    public async Task TestAsyncEvents()
+    {
+        using var q = new InMemoryQueue<SimpleWorkItem>(o => o.LoggerFactory(Log));
+        var disposables = new List<IDisposable>(5);
+        try
+        {
+            disposables.Add(q.Enqueuing.AddHandler(async (sender, args) =>
+            {
+                await Task.Delay(250);
+                _logger.LogInformation("First Enqueuing");
+            }));
+            disposables.Add(q.Enqueuing.AddHandler(async (sender, args) =>
+            {
+                await Task.Delay(250);
+                _logger.LogInformation("Second Enqueuing");
+            }));
+            disposables.Add(q.Enqueued.AddHandler(async (sender, args) =>
+            {
+                await Task.Delay(250);
+                _logger.LogInformation("First");
+            }));
+            disposables.Add(q.Enqueued.AddHandler(async (sender, args) =>
+            {
+                await Task.Delay(250);
+                _logger.LogInformation("Second");
+            }));
+
+            var sw = Stopwatch.StartNew();
+            await q.EnqueueAsync(new SimpleWorkItem());
+            sw.Stop();
+            if (_logger.IsEnabled(LogLevel.Trace)) _logger.LogTrace("Time {Elapsed:g}", sw.Elapsed);
+
+            sw.Restart();
+            await q.EnqueueAsync(new SimpleWorkItem());
+            sw.Stop();
+            if (_logger.IsEnabled(LogLevel.Trace)) _logger.LogTrace("Time {Elapsed:g}", sw.Elapsed);
+        }
+        finally
+        {
+            foreach (var disposable in disposables)
+                disposable.Dispose();
+        }
+    }
+
+    [Fact]
+    public async Task CanGetCompletedEntries()
+    {
+        using var q = new InMemoryQueue<SimpleWorkItem>(o => o.LoggerFactory(Log).CompletedEntryRetentionLimit(10));
+
+        await q.EnqueueAsync(new SimpleWorkItem());
+        Assert.Single(q.GetEntries());
+        Assert.Empty(q.GetDequeuedEntries());
+        Assert.Empty(q.GetCompletedEntries());
+
+        var item = await q.DequeueAsync();
+        Assert.Empty(q.GetEntries());
+        Assert.Single(q.GetDequeuedEntries());
+        Assert.Empty(q.GetCompletedEntries());
+
+        await item.CompleteAsync();
+        Assert.Empty(q.GetEntries());
+        Assert.Empty(q.GetDequeuedEntries());
+        Assert.Single(q.GetCompletedEntries());
+
+        for (int i = 0; i < 100; i++)
+        {
+            await q.EnqueueAsync(new SimpleWorkItem());
+            item = await q.DequeueAsync();
+            await item.CompleteAsync();
+        }
+
+        Assert.Empty(q.GetEntries());
+        Assert.Empty(q.GetDequeuedEntries());
+        Assert.Equal(10, q.GetCompletedEntries().Count);
+    }
+
     #region Issue239
 
     class QueueEntry_Issue239<T> : IQueueEntry<T> where T : class