File tree Expand file tree Collapse file tree 10 files changed +17
-12
lines changed
main/java/org/sterl/spring/persistent_tasks
test/java/org/sterl/spring/persistent_tasks/history Expand file tree Collapse file tree 10 files changed +17
-12
lines changed Original file line number Diff line number Diff line change 11mvn versions: display-dependency-updates
2- mvn versions: set -DnewVersion=1.5.3 -DgenerateBackupPoms=false
2+ mvn versions: set -DnewVersion=1.5.5 -DgenerateBackupPoms=false
33git tag -a v1.5.3 -m "v1.5.3 release"
44mvn versions: set -DnewVersion=1.5.4-SNAPSHOT -DgenerateBackupPoms=false
55
Original file line number Diff line number Diff line change 66 <parent >
77 <groupId >org.sterl.spring</groupId >
88 <artifactId >spring-persistent-tasks-root</artifactId >
9- <version >1.5.5 -SNAPSHOT</version >
9+ <version >1.5.4 -SNAPSHOT</version >
1010 <relativePath >../pom.xml</relativePath >
1111 </parent >
1212
Original file line number Diff line number Diff line change 1010import java .util .concurrent .Future ;
1111
1212import org .springframework .lang .NonNull ;
13+ import org .springframework .transaction .annotation .Propagation ;
1314import org .springframework .transaction .annotation .Transactional ;
1415import org .springframework .transaction .event .TransactionPhase ;
1516import org .springframework .transaction .event .TransactionalEventListener ;
@@ -105,6 +106,7 @@ public List<Future<TriggerKey>> triggerNextTasks() {
105106 * This method should not be called in a transaction!
106107 * </p>
107108 */
109+ @ Transactional (propagation = Propagation .NEVER )
108110 @ NonNull
109111 public List <Future <TriggerKey >> triggerNextTasks (OffsetDateTime timeDue ) {
110112 if (taskExecutor .getFreeThreads () > 0 ) {
Original file line number Diff line number Diff line change @@ -32,19 +32,19 @@ public Optional<TriggerEntity> execute(TriggerEntity trigger) {
3232 return Optional .empty ();
3333 }
3434
35- final var taskAndState = getTastAndState (trigger );
35+ final var runTaskWithState = buildTaskWithStateFor (trigger );
3636 // something went really wrong this trigger is crap
37- if (taskAndState == null ) return Optional .of (trigger );
37+ if (runTaskWithState == null ) return Optional .of (trigger );
3838
3939 try {
40- return taskAndState .execute (editTrigger );
40+ return runTaskWithState .execute (editTrigger );
4141 } catch (Exception e ) {
42- return failTaskAndState (taskAndState , e );
42+ return failTaskAndState (runTaskWithState , e );
4343 }
4444 }
4545
4646 @ Nullable
47- private RunTaskWithStateCommand getTastAndState (TriggerEntity trigger ) {
47+ private RunTaskWithStateCommand buildTaskWithStateFor (TriggerEntity trigger ) {
4848 try {
4949 final var task = taskService .assertIsKnown (trigger .newTaskId ());
5050 final var trx = taskService .getTransactionTemplate (task );
Original file line number Diff line number Diff line change @@ -17,8 +17,10 @@ public record RunTaskWithStateCommand (
1717
1818 public Optional <TriggerEntity > execute (EditTriggerComponent editTrigger ) {
1919 if (trx .isPresent ()) {
20+ System .err .println ("IN TRX" );
2021 return trx .get ().execute (t -> runTask (editTrigger ));
2122 } else {
23+ System .err .println ("NO TRX" );
2224 return runTask (editTrigger );
2325 }
2426 }
Original file line number Diff line number Diff line change 1717
1818class HistoryServiceTest extends AbstractSpringTest {
1919
20- @ Autowired HistoryService subject ;
20+ @ Autowired
21+ private HistoryService subject ;
2122
2223 @ Test
2324 void testReQueueTrigger () {
Original file line number Diff line number Diff line change 66 <parent >
77 <groupId >org.sterl.spring</groupId >
88 <artifactId >spring-persistent-tasks-root</artifactId >
9- <version >1.5.5 -SNAPSHOT</version >
9+ <version >1.5.4 -SNAPSHOT</version >
1010 <relativePath >../pom.xml</relativePath >
1111 </parent >
1212
Original file line number Diff line number Diff line change 66 <parent >
77 <groupId >org.sterl.spring</groupId >
88 <artifactId >spring-persistent-tasks-root</artifactId >
9- <version >1.5.5 -SNAPSHOT</version >
9+ <version >1.5.4 -SNAPSHOT</version >
1010 <relativePath >../pom.xml</relativePath >
1111 </parent >
1212
Original file line number Diff line number Diff line change 1111
1212 <groupId >org.sterl.spring</groupId >
1313 <artifactId >spring-persistent-tasks-root</artifactId >
14- <version >1.5.5 -SNAPSHOT</version >
14+ <version >1.5.4 -SNAPSHOT</version >
1515 <packaging >pom</packaging >
1616
1717 <inceptionYear >2024</inceptionYear >
Original file line number Diff line number Diff line change 66 <parent >
77 <groupId >org.sterl.spring</groupId >
88 <artifactId >spring-persistent-tasks-root</artifactId >
9- <version >1.5.5 -SNAPSHOT</version >
9+ <version >1.5.4 -SNAPSHOT</version >
1010 <relativePath >../pom.xml</relativePath >
1111 </parent >
1212
You can’t perform that action at this time.
0 commit comments