- fixes

Author: eben-roux

Shuttle.Core.Threading/ProcessorThread.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Threading;
 using Shuttle.Core.Configuration;
+using Shuttle.Core.Contract;
 using Shuttle.Core.Logging;
 using Shuttle.Core.Reflection;
 
@@ -21,6 +22,8 @@ public class ProcessorThread : IThreadState
 
         public ProcessorThread(string name, IProcessor processor)
         {
+            Guard.AgainstNull(processor, nameof(processor));
+
             _name = name;
             _processor = processor;
 

Shuttle.Core.Threading/ProcessorThreadPool.cs

@@ -20,7 +20,7 @@ public ProcessorThreadPool(string name, int threadCount, IProcessorFactory proce
         {
             Guard.AgainstNull(processorFactory, nameof(processorFactory));
 
-            if (_threadCount < 1)
+            if (threadCount < 1)
             {
                 throw new ThreadCountZeroException();
             }