event Handler如果抛非IO异常，则不重试；只有IOException才进行重试。

fftlzyf · Mar 29, 2016 · 07c4e91 · 07c4e91
1 parent d39f1d3
commit 07c4e91
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/src/ENode/Infrastructure/Impl/DefaultMessageDispatcher.cs b/src/ENode/Infrastructure/Impl/DefaultMessageDispatcher.cs
@@ -264,8 +264,7 @@ private void HandleSingleMessageAsync(SingleMessageDisptaching singleMessageDisp
             },
             () => string.Format("[messageId:{0}, messageType:{1}, handlerType:{2}]", message.Id, message.GetType().Name, handlerProxy.GetInnerObject().GetType().Name),
             null,
-            retryTimes,
-            true);
+            retryTimes);
         }
         private void HandleTwoMessageAsync(MultiMessageDisptaching multiMessageDispatching, IMessageHandlerProxy2 handlerProxy, string handlerTypeName, QueuedHandler<IMessageHandlerProxy2> queueHandler, int retryTimes)
         {
@@ -301,8 +300,7 @@ private void HandleTwoMessageAsync(MultiMessageDisptaching multiMessageDispatchi
             },
             () => string.Format("[messages:[{0}], handlerType:{1}]", string.Join("|", messages.Select(x => string.Format("id:{0},type:{1}", x.Id, x.GetType().Name))), handlerProxy.GetInnerObject().GetType().Name),
             null,
-            retryTimes,
-            true);
+            retryTimes);
         }
         private void HandleThreeMessageAsync(MultiMessageDisptaching multiMessageDispatching, IMessageHandlerProxy3 handlerProxy, string handlerTypeName, QueuedHandler<IMessageHandlerProxy3> queueHandler, int retryTimes)
         {
@@ -342,8 +340,7 @@ private void HandleThreeMessageAsync(MultiMessageDisptaching multiMessageDispatc
             },
             () => string.Format("[messages:[{0}], handlerType:{1}]", string.Join("|", messages.Select(x => string.Format("id:{0},type:{1}", x.Id, x.GetType().Name))), handlerProxy.GetInnerObject().GetType().Name),
             null,
-            retryTimes,
-            true);
+            retryTimes);
         }
 
         private void AddMessageHandledRecordAsync(SingleMessageDisptaching singleMessageDispatching, MessageHandleRecord messageHandleRecord, Type handlerType, string handlerTypeName, IMessageHandlerProxy1 handlerProxy, QueuedHandler<IMessageHandlerProxy1> queueHandler, int retryTimes)