1
1
/*
2
- * Copyright 2002-2022 the original author or authors.
2
+ * Copyright 2002-2023 the original author or authors.
3
3
*
4
4
* Licensed under the Apache License, Version 2.0 (the "License");
5
5
* you may not use this file except in compliance with the License.
@@ -22,7 +22,7 @@ import org.assertj.core.api.Assertions.assertThat
22
22
import org.assertj.core.api.Fail
23
23
import org.junit.jupiter.api.BeforeEach
24
24
import org.junit.jupiter.api.Test
25
- import org.mockito.BDDMockito
25
+ import org.mockito.BDDMockito.*
26
26
import org.mockito.Mockito
27
27
import org.springframework.transaction.*
28
28
import org.springframework.transaction.reactive.TransactionContext
@@ -83,8 +83,8 @@ abstract class AbstractCoroutinesTransactionAspectTests {
83
83
val status = Mockito .mock(ReactiveTransaction ::class .java)
84
84
val rtm = Mockito .mock(ReactiveTransactionManager ::class .java)
85
85
// expect a transaction
86
- BDDMockito . given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
87
- BDDMockito . given(rtm.commit(status)).willReturn(Mono .empty())
86
+ given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
87
+ given(rtm.commit(status)).willReturn(Mono .empty())
88
88
val tb = DefaultTestBean ()
89
89
val itb = advised(tb, rtm, tas) as TestBean
90
90
runBlocking {
@@ -106,8 +106,8 @@ abstract class AbstractCoroutinesTransactionAspectTests {
106
106
val status = Mockito .mock(ReactiveTransaction ::class .java)
107
107
val rtm = Mockito .mock(ReactiveTransactionManager ::class .java)
108
108
// expect a transaction
109
- BDDMockito . given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
110
- BDDMockito . given(rtm.commit(status)).willReturn(Mono .empty())
109
+ given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
110
+ given(rtm.commit(status)).willReturn(Mono .empty())
111
111
val tb = DefaultTestBean ()
112
112
val itb = advised(tb, rtm, arrayOf(tas1, tas2)) as TestBean
113
113
runBlocking {
@@ -128,8 +128,8 @@ abstract class AbstractCoroutinesTransactionAspectTests {
128
128
val status = Mockito .mock(ReactiveTransaction ::class .java)
129
129
val rtm = Mockito .mock(ReactiveTransactionManager ::class .java)
130
130
// expect a transaction
131
- BDDMockito . given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
132
- BDDMockito . given(rtm.commit(status)).willReturn(Mono .empty())
131
+ given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
132
+ given(rtm.commit(status)).willReturn(Mono .empty())
133
133
val tb = DefaultTestBean ()
134
134
val itb = advised(tb, rtm, tas) as TestBean
135
135
runBlocking {
@@ -198,17 +198,17 @@ abstract class AbstractCoroutinesTransactionAspectTests {
198
198
val status = Mockito .mock(ReactiveTransaction ::class .java)
199
199
val rtm = Mockito .mock(ReactiveTransactionManager ::class .java)
200
200
// Gets additional call(s) from TransactionControl
201
- BDDMockito . given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
201
+ given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
202
202
val tex = TransactionSystemException (" system exception" )
203
203
if (rollbackException) {
204
204
if (shouldRollback) {
205
- BDDMockito . given(rtm.rollback(status)).willReturn(Mono .error(tex))
205
+ given(rtm.rollback(status)).willReturn(Mono .error(tex))
206
206
} else {
207
- BDDMockito . given(rtm.commit(status)).willReturn(Mono .error(tex))
207
+ given(rtm.commit(status)).willReturn(Mono .error(tex))
208
208
}
209
209
} else {
210
- BDDMockito . given(rtm.commit(status)).willReturn(Mono .empty())
211
- BDDMockito . given(rtm.rollback(status)).willReturn(Mono .empty())
210
+ given(rtm.commit(status)).willReturn(Mono .empty())
211
+ given(rtm.rollback(status)).willReturn(Mono .empty())
212
212
}
213
213
val tb = DefaultTestBean ()
214
214
val itb = advised(tb, rtm, tas) as TestBean
@@ -246,7 +246,7 @@ abstract class AbstractCoroutinesTransactionAspectTests {
246
246
val rtm = Mockito .mock(ReactiveTransactionManager ::class .java)
247
247
// Expect a transaction
248
248
val ex = CannotCreateTransactionException (" foobar" )
249
- BDDMockito . given(rtm.getReactiveTransaction(txatt)).willThrow(ex)
249
+ given(rtm.getReactiveTransaction(txatt)).willThrow(ex)
250
250
val tb: DefaultTestBean = object : DefaultTestBean () {
251
251
override suspend fun getName (): String? {
252
252
throw UnsupportedOperationException (
@@ -279,10 +279,10 @@ abstract class AbstractCoroutinesTransactionAspectTests {
279
279
// No attributes for m2
280
280
val rtm = Mockito .mock(ReactiveTransactionManager ::class .java)
281
281
val status = Mockito .mock(ReactiveTransaction ::class .java)
282
- BDDMockito . given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
282
+ given(rtm.getReactiveTransaction(txatt)).willReturn(Mono .just(status))
283
283
val ex = UnexpectedRollbackException (" foobar" )
284
- BDDMockito . given(rtm.commit(status)).willReturn(Mono .error(ex))
285
- BDDMockito . given(rtm.rollback(status)).willReturn(Mono .empty())
284
+ given(rtm.commit(status)).willReturn(Mono .error(ex))
285
+ given(rtm.rollback(status)).willReturn(Mono .empty())
286
286
val tb = DefaultTestBean ()
287
287
val itb = advised(tb, rtm, tas) as TestBean
288
288
val name = " new name"
0 commit comments