Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use unique DB ids in PulsarTemplateWithDbTransactionTests

Browse Source
This commit is contained in:
Chris Bono
2024-05-09 10:46:46 -05:00
parent 2ab61de46c
commit 4939d03529
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-pulsar/src/test/java/org/springframework/pulsar/transaction/PulsarTemplateWithDbTransactionTests.java
View File

@@ -50,7 +50,7 @@ class PulsarTemplateWithDbTransactionTests extends PulsarTxnWithDbTxnTestsBase {
@Test
void whenDbTxnIsCommittedThenMessagesAreCommitted(@Autowired TestService transactionalService) {
var thing1 = new Thing(1L, "msg1");
var thing1 = new Thing(100L, "msg1");
transactionalService.handleRequest(thing1, false, false);
assertThatMessagesAreInTopic(topic, thing1.name());
assertThatMessagesAreInDb(thing1);
@@ -58,7 +58,7 @@ class PulsarTemplateWithDbTransactionTests extends PulsarTxnWithDbTxnTestsBase {
@Test
void whenDbTxnIsSetRollbackOnlyThenMessagesAreNotCommitted(@Autowired TestService transactionalService) {
var thing2 = new Thing(2L, "msg2");
var thing2 = new Thing(200L, "msg2");
transactionalService.handleRequest(thing2, true, false);
assertThatMessagesAreNotInTopic(topic, thing2.name());
assertThatMessagesAreNotInDb(thing2);
@@ -66,7 +66,7 @@ class PulsarTemplateWithDbTransactionTests extends PulsarTxnWithDbTxnTestsBase {
@Test
void whenServiceThrowsExceptionThenMessagesAreNotCommitted(@Autowired TestService transactionalService) {
var thing3 = new Thing(3L, "msg3");
var thing3 = new Thing(300L, "msg3");
assertThatExceptionOfType(PulsarException.class)
.isThrownBy(() -> transactionalService.handleRequest(thing3, false, true))
.withMessage("Failed to commit due to chaos");