failing task may succeed

Author: sterlp

example/src/main/java/org/sterl/spring/example_app/vehicle/task/BuildVehicleTask.java

@@ -1,23 +1,25 @@
 package org.sterl.spring.example_app.vehicle.task;
 
+import java.util.Random;
+
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 import org.sterl.spring.example_app.vehicle.model.Vehicle;
 import org.sterl.spring.example_app.vehicle.repository.VehicleRepository;
-import org.sterl.spring.persistent_tasks.api.SpringBeanTask;
 import org.sterl.spring.persistent_tasks.api.TaskId;
+import org.sterl.spring.persistent_tasks.api.TransactionalTask;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 @Component(BuildVehicleTask.NAME)
 @RequiredArgsConstructor
 @Slf4j
-public class BuildVehicleTask implements SpringBeanTask<Vehicle> {
+public class BuildVehicleTask implements TransactionalTask<Vehicle> {
 
     static final String NAME = "buildVehicleTask";
     public static final TaskId<Vehicle> ID = new TaskId<>(NAME);
-
+    private final Random random = new Random();
     private final VehicleRepository vehicleRepository;
 
     @Transactional(timeout = 5)
@@ -26,7 +28,7 @@ public void accept(Vehicle vehicle) {
         vehicleRepository.save(vehicle);
         log.info("Create vehicle ={}", vehicle);
         try {
-            Thread.sleep(1500);
+            Thread.sleep(random.nextInt(3501));
         } catch (InterruptedException e) {
             Thread.interrupted();
         }

example/src/main/java/org/sterl/spring/example_app/vehicle/task/FailingBuildVehicleTask.java

@@ -1,33 +1,36 @@
 package org.sterl.spring.example_app.vehicle.task;
 
+import java.util.Random;
+
 import org.springframework.stereotype.Component;
 import org.sterl.spring.example_app.vehicle.model.Vehicle;
 import org.sterl.spring.example_app.vehicle.repository.VehicleRepository;
-import org.sterl.spring.persistent_tasks.api.SpringBeanTask;
 import org.sterl.spring.persistent_tasks.api.TaskId;
+import org.sterl.spring.persistent_tasks.api.TransactionalTask;
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 @Component(FailingBuildVehicleTask.NAME)
 @RequiredArgsConstructor
 @Slf4j
-public class FailingBuildVehicleTask implements SpringBeanTask<Vehicle> {
+public class FailingBuildVehicleTask implements TransactionalTask<Vehicle> {
 
     static final String NAME = "failingBuildVehicleTask";
     public static final TaskId<Vehicle> ID = new TaskId<>(NAME);
-
+    private final Random random = new Random();
     private final VehicleRepository vehicleRepository;
 
     @Override
     public void accept(Vehicle vehicle) {
         vehicleRepository.save(vehicle);
         log.info("Create vehicle with {} - which will fail", vehicle);
         try {
-            Thread.sleep(3500);
+            Thread.sleep(random.nextInt(3501));
         } catch (InterruptedException e) {
             Thread.interrupted();
         }
-        throw new RuntimeException("This persistentTask will always fail!");
+        if (random.nextInt(11) % 2 == 0)
+            throw new RuntimeException("This persistentTask will always fail!");
     }
 }