@@ -105,7 +105,7 @@ public class TestTool {
105105 private @ Setter @ Getter @ Inject @ Autowired Views views ;
106106 private @ Setter @ Getter int reportsInProgressThreshold = 300000 ;
107107 boolean devMode = false ; // See testConcurrentLastEndpointAndFirstStartpointForSameCorrelationId()
108- private @ Setter String openTelemetryEndpoint ;
108+ private @ Setter String openTelemetryEndpoint ;
109109 private Tracer tracer ;
110110
111111 private @ Getter @ Setter String host = null ;
@@ -144,7 +144,7 @@ public void reset() {
144144 reportGeneratorEnabled = defaultReportGeneratorEnabled ;
145145 }
146146
147- public void setSecurityLoggerName (String securityLoggerName ) {
147+ public void setSecurityLoggerName (String securityLoggerName ) {
148148 securityLog = LoggerFactory .getLogger (securityLoggerName );
149149 }
150150
@@ -366,33 +366,17 @@ private <T> T checkpoint(String correlationId, String childThreadId, String sour
366366 matchingStubStrategies , checkpointType , levelChangeNextCheckpoint , true );
367367 }
368368
369- private <T > T checkpoint (String correlationId , String childThreadId , String sourceClassName , String name ,
370- T message , Map <String , Object > messageContext , StubableCode stubableCode , StubableCodeThrowsException stubableCodeThrowsException ,
371- Set <String > matchingStubStrategies , int checkpointType , int levelChangeNextCheckpoint ) {
372- return checkpoint (correlationId , childThreadId , sourceClassName , name ,
373- message , messageContext , stubableCode , stubableCodeThrowsException ,
374- matchingStubStrategies , checkpointType , levelChangeNextCheckpoint , true );
375- }
376-
377- private <T > T checkpoint (String correlationId , String childThreadId , String sourceClassName , String name ,
378- T message , StubableCode stubableCode , StubableCodeThrowsException stubableCodeThrowsException ,
379- Set <String > matchingStubStrategies , int checkpointType , int levelChangeNextCheckpoint , boolean shouldBeRerunnable ) {
380- return checkpoint (correlationId , childThreadId , sourceClassName , name ,
381- message , null , stubableCode , stubableCodeThrowsException ,
382- matchingStubStrategies , checkpointType , levelChangeNextCheckpoint , shouldBeRerunnable );
383- }
384-
385369 private <T > T checkpoint (String correlationId , String childThreadId , String sourceClassName , String name ,
386370 T message , Map <String , Object > messageContext , StubableCode stubableCode , StubableCodeThrowsException stubableCodeThrowsException ,
387- Set <String > matchingStubStrategies , int checkpointType , int levelChangeNextCheckpoint , boolean shouldBeRerunnable ) {
371+ Set <String > matchingStubStrategies , int checkpointType , int levelChangeNextCheckpoint ) {
388372 boolean executeStubableCode = true ;
389373 if (reportGeneratorEnabled ) {
390374 Report report ;
391375 // Blocking for all threads for all reports
392376 synchronized (reportsInProgress ) {
393377 report = getReportInProgress (correlationId );
394378 if (report == null ) {
395- report = createReport (correlationId , name , checkpointType , shouldBeRerunnable );
379+ report = createReport (correlationId , name , checkpointType );
396380 }
397381 }
398382 if (devMode ) randomSleep ();
@@ -412,7 +396,7 @@ private <T> T checkpoint(String correlationId, String childThreadId, String sour
412396 synchronized (reportsInProgress ) {
413397 report = getReportInProgress (correlationId );
414398 if (report == null ) {
415- report = createReport (correlationId , name , checkpointType , shouldBeRerunnable );
399+ report = createReport (correlationId , name , checkpointType );
416400 }
417401 }
418402 // Synchronize and check isClosed() on report again as it will now point to a different report
@@ -433,7 +417,7 @@ private <T> T checkpoint(String correlationId, String childThreadId, String sour
433417 return message ;
434418 }
435419
436- private Report createReport (String correlationId , String name , int checkpointType , boolean shouldBeRerunnable ) {
420+ private Report createReport (String correlationId , String name , int checkpointType ) {
437421 Report report = null ;
438422 if (checkpointType == CheckpointType .STARTPOINT .toInt ()) {
439423 log .debug ("Create new report for '" + correlationId + "'" );
@@ -453,7 +437,6 @@ private Report createReport(String correlationId, String name, int checkpointTyp
453437 report .setReportFilterMatching (false );
454438 }
455439 }
456- report .setRerunnable (shouldBeRerunnable );
457440 Report originalReport ;
458441 synchronized (originalReports ) {
459442 originalReport = (Report )originalReports .remove (correlationId );
@@ -569,11 +552,6 @@ public <T> T startpoint(String correlationId, String sourceClassName, String nam
569552 CheckpointType .STARTPOINT .toInt (), 1 );
570553 }
571554
572- public <T > T startpoint (String correlationId , String sourceClassName , String name , T message , boolean shouldBeRerunnable ) {
573- return checkpoint (correlationId , null , sourceClassName , name , message , null , null , null ,
574- CheckpointType .STARTPOINT .toInt (), 1 , shouldBeRerunnable );
575- }
576-
577555 public <T > T startpoint (String correlationId , String sourceClassName , String name , T message , Map <String , Object > messageContext ) {
578556 return checkpoint (correlationId , null , sourceClassName , name , message , messageContext , null , null , null ,
579557 CheckpointType .STARTPOINT .toInt (), 1 );
0 commit comments