diff --git a/src/test/java/org/springframework/data/r2dbc/connectionfactory/TransactionAwareConnectionFactoryProxyUnitTests.java b/src/test/java/org/springframework/data/r2dbc/connectionfactory/TransactionAwareConnectionFactoryProxyUnitTests.java index 199777d..b8bac92 100644 --- a/src/test/java/org/springframework/data/r2dbc/connectionfactory/TransactionAwareConnectionFactoryProxyUnitTests.java +++ b/src/test/java/org/springframework/data/r2dbc/connectionfactory/TransactionAwareConnectionFactoryProxyUnitTests.java @@ -134,7 +134,7 @@ public class TransactionAwareConnectionFactoryProxyUnitTests { public void shouldEmitBoundConnection() { when(connectionMock1.beginTransaction()).thenReturn(Mono.empty()); - when(connectionMock1.commitTransaction()).thenReturn(Mono.error(new IllegalStateException())); + when(connectionMock1.commitTransaction()).thenReturn(Mono.empty()); when(connectionMock1.close()).thenReturn(Mono.empty()); TransactionalOperator rxtx = TransactionalOperator.create(tm);