@@ -104,7 +104,7 @@ public void handleMessage_ignore() {
104
104
spec ,
105
105
asyncRunner ,
106
106
(b , __ ) -> SafeFuture .completedFuture (InternalValidationResult .IGNORE ),
107
- null );
107
+ debugDataDumper );
108
108
109
109
final SafeFuture <ValidationResult > result =
110
110
topicHandler .handleMessage (topicHandler .prepareMessage (blockBytes , Optional .empty ()));
@@ -210,7 +210,7 @@ public void handleMessage_errorWhileProcessing_rejectedExecution() {
210
210
(b , __ ) -> {
211
211
throw new RejectedExecutionException ("No more capacity" );
212
212
},
213
- null );
213
+ debugDataDumper );
214
214
215
215
final SafeFuture <ValidationResult > result =
216
216
topicHandler .handleMessage (topicHandler .prepareMessage (blockBytes , Optional .empty ()));
@@ -229,7 +229,7 @@ public void handleMessage_errorWhileProcessing_wrappedRejectedExecution() {
229
229
(b , __ ) -> {
230
230
throw new CompletionException (new RejectedExecutionException ("No more capacity" ));
231
231
},
232
- null );
232
+ debugDataDumper );
233
233
234
234
final SafeFuture <ValidationResult > result =
235
235
topicHandler .handleMessage (topicHandler .prepareMessage (blockBytes , Optional .empty ()));
@@ -248,7 +248,7 @@ public void handleMessage_errorWhileProcessing_rejectedExecutionWithRootCause()
248
248
(b , __ ) -> {
249
249
throw new RejectedExecutionException ("No more capacity" , new NullPointerException ());
250
250
},
251
- null );
251
+ debugDataDumper );
252
252
253
253
final SafeFuture <ValidationResult > result =
254
254
topicHandler .handleMessage (topicHandler .prepareMessage (blockBytes , Optional .empty ()));
@@ -267,7 +267,7 @@ public void handleMessage_errorWhileProcessing_serviceCapacityExceededExecution(
267
267
(b , __ ) -> {
268
268
throw new ServiceCapacityExceededException ("No more capacity" );
269
269
},
270
- null );
270
+ debugDataDumper );
271
271
272
272
final SafeFuture <ValidationResult > result =
273
273
topicHandler .handleMessage (topicHandler .prepareMessage (blockBytes , Optional .empty ()));
@@ -287,7 +287,7 @@ public void handleMessage_errorWhileProcessing_wrappedServiceCapacityExceededExe
287
287
throw new CompletionException (
288
288
new ServiceCapacityExceededException ("No more capacity" ));
289
289
},
290
- null );
290
+ debugDataDumper );
291
291
292
292
final SafeFuture <ValidationResult > result =
293
293
topicHandler .handleMessage (topicHandler .prepareMessage (blockBytes , Optional .empty ()));
@@ -306,7 +306,7 @@ public void handleMessage_errorWhileProcessing_unknownError() {
306
306
(b , __ ) -> {
307
307
throw new NullPointerException ();
308
308
},
309
- null );
309
+ debugDataDumper );
310
310
311
311
final SafeFuture <ValidationResult > result =
312
312
topicHandler .handleMessage (topicHandler .prepareMessage (blockBytes , Optional .empty ()));
0 commit comments