Fixed plugable queue balancer test failures.

- Was not setting the blancer type.

Author: jason-bragg

test/Tester/StreamingTests/PlugableQueueBalancerTests/PluggableQueueBalancerTestBase.cs

@@ -13,12 +13,6 @@ public class PluggableQueueBalancerTestBase : OrleansTestingBase
     {
         private static Type QueueBalancerType = typeof(LeaseBasedQueueBalancerForTest);
 
-        public static PersistentStreamOptions ConfigWithCustomBalancerType(PersistentStreamOptions options)
-        {
-            options.BalancerType = QueueBalancerType;
-            return options;
-        }
-
         public virtual async Task ShouldUseInjectedQueueBalancerAndBalanceCorrectly(BaseTestClusterFixture fixture, string streamProviderName, int siloCount, int totalQueueCount)
         {
             var leaseManager = fixture.GrainFactory.GetGrain<ILeaseManagerGrain>(streamProviderName);

test/Tester/StreamingTests/PlugableQueueBalancerTests/PluggableQueueBalancerTestsWithMemoryStreamProvider.cs

@@ -41,6 +41,7 @@ public void Configure(ISiloHostBuilder hostBuilder)
                         .AddMemoryStreams<DefaultMemoryMessageBodySerializer>(StreamProviderName, options =>
                         {
                             options.TotalQueueCount = totalQueueCount;
+                            options.BalancerType = typeof(LeaseBasedQueueBalancerForTest);
                         });
                 }
             }