File tree Expand file tree Collapse file tree
Stream/Vertex.Stream.RabbitMQ/Consumer
Vertex.Abstractions/Snapshot Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -98,7 +98,7 @@ public Task Run()
9898 $ "An error occurred in { this . Queue } ") ;
9999 foreach ( var item in list . Where ( o => ! o . Success ) )
100100 {
101- this . Model . Model . BasicReject ( ( ( BasicGetResult ) item . Origin ) . DeliveryTag , true ) ;
101+ this . Model . Model . BasicReject ( ( ( BasicGetResult ) item . Origin ) . DeliveryTag , true ) ;
102102 }
103103 }
104104 finally
Original file line number Diff line number Diff line change @@ -7,7 +7,9 @@ public record SnapshotMeta<TPrimaryKey>
77 public long DoingVersion { get ; set ; }
88
99 public long Version { get ; set ; }
10+
1011 public long MinEventTimestamp { get ; set ; }
12+
1113 public long MinEventVersion { get ; set ; }
1214
1315 public bool IsLatest { get ; set ; }
Original file line number Diff line number Diff line change 2525using Vertex . Runtime . Exceptions ;
2626using Vertex . Runtime . Options ;
2727using Vertex . Utils . Emit ;
28- using Vertex . Abstractions . Event ;
2928
3029namespace Vertex . Runtime . Actor
3130{
You can’t perform that action at this time.
0 commit comments