ObserverGrain订阅方法移除不重试

Administrator · u-less · commit f6ef55a224bf · 2020-04-13T13:27:29.000+08:00
diff --git a/src/Ray.Core/Core/Grains/ObserverGrain.cs b/src/Ray.Core/Core/Grains/ObserverGrain.cs
@@ -623,6 +623,7 @@ protected virtual async ValueTask EventDelivered(FullyEvent<PrimaryKey> fullyEve
             catch (Exception ex)
             {
                 Logger.LogCritical(ex, "Delivered failed: {0}->{1}->{2}", GrainType.FullName, GrainId.ToString(), Serializer.Serialize(fullyEvent, fullyEvent.GetType()));
+                throw ex;
             }
         }
         public Task DefaultHandler(IEvent evt)

Original file line number	Diff line number	Diff line change
`@@ -623,6 +623,7 @@ protected virtual async ValueTask EventDelivered(FullyEvent<PrimaryKey> fullyEve`
`623`	`623`	`catch (Exception ex)`
`624`	`624`	`{`
`625`	`625`	`Logger.LogCritical(ex, "Delivered failed: {0}->{1}->{2}", GrainType.FullName, GrainId.ToString(), Serializer.Serialize(fullyEvent, fullyEvent.GetType()));`
	`626`	`+ throw ex;`
`626`	`627`	`}`
`627`	`628`	`}`
`628`	`629`	`public Task DefaultHandler(IEvent evt)`