File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
server/src/main/java/io/spine/server/aggregate Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -346,9 +346,12 @@ final BatchDispatchOutcome replay(AggregateHistory history) {
346
346
final BatchDispatchOutcome apply (List <Event > events , int snapshotTrigger ) {
347
347
var versionSequence = new VersionSequence (version ());
348
348
var versionedEvents = versionSequence .update (events );
349
+ System .out .println ("Batch size: " + events .size ());
349
350
uncommittedHistory .startTracking (snapshotTrigger );
350
351
var result = play (versionedEvents );
352
+ System .out .println ("Batch successful ? " + result .getSuccessful ());
351
353
uncommittedHistory .stopTracking ();
354
+ System .out .println ("Uncommitted size: " + uncommittedHistory .events ().list ().size ());
352
355
return result ;
353
356
}
354
357
@@ -412,8 +415,7 @@ UncommittedHistory uncommittedHistory() {
412
415
* the {@link io.spine.server.entity.RecentHistory RecentHistory} and clears them.
413
416
*/
414
417
final void commitEvents () {
415
- List <Event > recentEvents = uncommittedHistory .events ()
416
- .list ();
418
+ List <Event > recentEvents = uncommittedHistory .events ().list ();
417
419
appendToRecentHistory (recentEvents );
418
420
uncommittedHistory .commit ();
419
421
}
You can’t perform that action at this time.
0 commit comments