From e03d1dc8ee72254901f32c629c85299034203b6f Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Wed, 22 May 2019 10:07:26 +0200 Subject: [PATCH] #55 - Polishing. Original pull request: #125. --- .../connectionfactory/R2dbcTransactionManagerUnitTests.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/test/java/org/springframework/data/r2dbc/connectionfactory/R2dbcTransactionManagerUnitTests.java b/src/test/java/org/springframework/data/r2dbc/connectionfactory/R2dbcTransactionManagerUnitTests.java index a9df5dd..afb2868 100644 --- a/src/test/java/org/springframework/data/r2dbc/connectionfactory/R2dbcTransactionManagerUnitTests.java +++ b/src/test/java/org/springframework/data/r2dbc/connectionfactory/R2dbcTransactionManagerUnitTests.java @@ -32,8 +32,7 @@ import java.util.concurrent.atomic.AtomicInteger; import org.junit.Before; import org.junit.Test; -import org.springframework.data.r2dbc.connectionfactory.R2dbcTransactionManager; -import org.springframework.data.r2dbc.connectionfactory.ConnectionFactoryUtils; + import org.springframework.transaction.IllegalTransactionStateException; import org.springframework.transaction.TransactionDefinition; import org.springframework.transaction.reactive.TransactionSynchronization; @@ -149,7 +148,7 @@ public class R2dbcTransactionManagerUnitTests { public void testCommitFails() { when(connectionMock.commitTransaction()).thenReturn(Mono.defer(() -> { - return Mono.error(new IllegalStateException()); + return Mono.error(new IllegalStateException("Commit should fail")); })); TransactionalOperator operator = TransactionalOperator.create(tm);