reintroduced assertion for commit count
This commit is contained in:
@@ -93,7 +93,8 @@ public class PollingTransactionTests {
|
||||
input.send(new GenericMessage<String>("test"));
|
||||
txManager.waitForCompletion(10000);
|
||||
Message<?> message = output.receive(0);
|
||||
assertNotNull(message);
|
||||
assertNotNull(message);
|
||||
assertEquals(1, txManager.getCommitCount());
|
||||
assertEquals(0, txManager.getRollbackCount());
|
||||
context.stop();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user