Explorar o código

Merge branch 'routing_exception' fixes #25

Kevin Lovato %!s(int64=10) %!d(string=hai) anos
pai
achega
096da09d2f
Modificáronse 1 ficheiros con 10 adicións e 0 borrados
  1. 10 0
      src/Abc.Zebus.Testing/TestBus.cs

+ 10 - 0
src/Abc.Zebus.Testing/TestBus.cs

@@ -247,6 +247,16 @@ namespace Abc.Zebus.Testing
             };
             };
         }
         }
 
 
+        public void AddHandlerThatThrowsDomainException<TMessage>(DomainException ex) where TMessage : IMessage
+        {
+            _handlers[new HandlerKey(typeof(TMessage), default(PeerId))] = x => { throw ex; };
+        }
+
+        public void AddHandlerThatThrows<TMessage>(Exception ex = null) where TMessage : IMessage
+        {
+            _handlers[new HandlerKey(typeof(TMessage), default(PeerId))] = x => { throw ex ?? new Exception(); };
+        }
+
         public void Expect(IEnumerable<IMessage> expectedMessages)
         public void Expect(IEnumerable<IMessage> expectedMessages)
         {
         {
             _messageComparer.CheckExpectations(Messages, expectedMessages, false);
             _messageComparer.CheckExpectations(Messages, expectedMessages, false);