1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.kuali.rice.test;
17
18 import org.kuali.rice.core.api.lifecycle.Lifecycle;
19 import org.kuali.rice.core.api.resourceloader.GlobalResourceLoader;
20 import org.springframework.transaction.PlatformTransactionManager;
21 import org.springframework.transaction.TransactionStatus;
22 import org.springframework.transaction.support.DefaultTransactionDefinition;
23
24
25
26
27
28 public class TransactionalLifecycle implements Lifecycle {
29
30 private static final org.apache.log4j.Logger LOG = org.apache.log4j.Logger
31 .getLogger(TransactionalLifecycle.class);
32
33
34
35
36
37 public static final String DEFAULT_TRANSACTION_MANAGER_NAME = "transactionManager";
38
39 private String transactionManagerName;
40 private PlatformTransactionManager transactionManager;
41
42 public TransactionalLifecycle(String transactionManagerName) {
43 this.transactionManagerName = transactionManagerName;
44 }
45
46 public TransactionalLifecycle() {
47 this(DEFAULT_TRANSACTION_MANAGER_NAME);
48 }
49
50 public void setTransactionManager(PlatformTransactionManager transactionManager) {
51 this.transactionManager = transactionManager;
52 }
53
54
55
56
57
58
59 private PlatformTransactionManager getTransactionManager() {
60 if (transactionManager == null) {
61 transactionManager = (PlatformTransactionManager) GlobalResourceLoader.getService(transactionManagerName);
62 }
63 return transactionManager;
64 }
65
66 private boolean started;
67 private TransactionStatus TRANSACTION_STATUS;
68
69 public boolean isStarted() {
70 return started;
71 }
72
73 public void start() throws Exception {
74 LOG.info("Starting a transaction from TransactionalLifecycle...");
75 DefaultTransactionDefinition defaultTransactionDefinition = new DefaultTransactionDefinition();
76 defaultTransactionDefinition.setTimeout(3600);
77 TRANSACTION_STATUS = getTransactionManager().getTransaction(defaultTransactionDefinition);
78 started = true;
79 }
80
81 public void stop() throws Exception {
82 LOG.info("...rolling back transaction from TransactionalLifecycle.");
83 getTransactionManager().rollback(TRANSACTION_STATUS);
84 started = false;
85 }
86
87 }