- @Test
- public void testForgetSuccessfulTransactions() throws Exception {
- ReadWriteTransaction transaction = mock(ReadWriteTransaction.class);
- successfulTxQ.add(transaction);
- pendingTransactions.add(transaction);
- transactionToCommand.put(transaction, mock(TransactionCommand.class));
- getField(TransactionInvokerImpl.class, "successfulTransactionQueue").set(transactionInvokerImpl, successfulTxQ);
- getField(TransactionInvokerImpl.class, "pendingTransactions").set(transactionInvokerImpl, pendingTransactions);
- getField(TransactionInvokerImpl.class, "transactionToCommand").set(transactionInvokerImpl,
- transactionToCommand);
-
- Whitebox.invokeMethod(transactionInvokerImpl, "forgetSuccessfulTransactions");
-
- List<ReadWriteTransaction> testPendingTransactions = Whitebox.getInternalState(transactionInvokerImpl,
- "pendingTransactions");
- Map<ReadWriteTransaction, TransactionCommand> testTransactionToCommand = Whitebox
- .getInternalState(transactionInvokerImpl, "transactionToCommand");
- assertTrue(testPendingTransactions.isEmpty());
- assertTrue(testTransactionToCommand.isEmpty());
- }
-