Added more EndpointConfiguration tests.

NuBus/EndPointConfiguration.cs

@@ -3,6 +3,7 @@
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
+using System.Threading;
 using NuBus.Adapter;
 using NuBus.Util;
 
@@ -158,22 +159,27 @@ protected void AddMessage(Type Message, MessageType mType)
 
         public void ClearHandlers()
         {
-            throw new NotImplementedException();
+            Interlocked.Exchange(ref _handlers, new ConcurrentBag<Type>());
         }
 
         public void ClearMessages()
         {
-            throw new NotImplementedException();
+            _messages.Clear();
         }
 
         public Type GetHandler(Type messageHandled)
         {
-            throw new NotImplementedException();
+            Condition.NotNull(messageHandled);
+
+            return GetHandlers()
+                .FirstOrDefault(
+                    h => h.FullName == messageHandled.FullName);
         }
 
         public Type GetHandler(string messageHandledFQCN)
         {
-            throw new NotImplementedException();
+            return GetHandlers()
+                .FirstOrDefault(h => h.FullName == messageHandledFQCN);
         }
 
         public IReadOnlyCollection<Type> GetHandlers()

NuBusTest/EndpointConfigurationTest.cs

@@ -121,5 +121,58 @@ public void TestMessageReceivedNotThrows()
 			Assert.DoesNotThrow(() => SpyAdapter.FireMessageReceivedHandlers(eventArgs));
 			Assert.IsTrue(Called);
 		}
+
+		[Test]
+		public void TestClearMessages()
+		{
+			var endpoint = new EndPointConfiguration(HostName, SpyAdapter);
+			Assert.Multiple(() => 
+			{
+				Assert.IsEmpty(endpoint.GetMessages());
+
+				endpoint.AddMessage(typeof(CommandOne));
+				Assert.IsNotEmpty(endpoint.GetMessages());
+
+				endpoint.ClearMessages();
+				Assert.IsEmpty(endpoint.GetMessages());
+			});
+		}
+
+		[Test]
+		public void TestGetHandler()
+		{
+			var endpoint = new EndPointConfiguration(HostName, SpyAdapter);
+			Assert.Multiple(() =>
+			{
+				var handlerType = typeof(Handler.CommandOneHandler); 
+				var handleName = handlerType.FullName;
+
+				Assert.IsNull(endpoint.GetHandler(handlerType));
+
+				endpoint.AddHandler(handlerType);
+				Assert.IsNotNull(endpoint.GetHandler(handleName));
+
+				endpoint.ClearHandlers();
+				Assert.IsEmpty(endpoint.GetHandlers());
+
+				Assert.IsNull(endpoint.GetHandler(string.Empty));
+			});
+		}
+
+		[Test]
+		public void TestClearHandlers()
+		{
+			var endpoint = new EndPointConfiguration(HostName, SpyAdapter);
+			Assert.Multiple(() =>
+			{
+				Assert.IsEmpty(endpoint.GetHandlers());
+
+				endpoint.AddHandler(typeof(Handler.CommandOneHandler));
+				Assert.IsNotEmpty(endpoint.GetHandlers());
+
+				endpoint.ClearHandlers();
+				Assert.IsEmpty(endpoint.GetHandlers());
+			});
+		}
 	}
 }