*/
@Test
public void testLimiterOnFailure() throws TimeoutException, InterruptedException {
- txContext.executeModification(DELETE);
- txContext.executeModification(DELETE);
+ txContext.executeModification(DELETE, null);
+ txContext.executeModification(DELETE, null);
assertEquals(2, limiter.availablePermits());
- Future<Object> future = txContext.sendBatchedModifications();
+ final Future<Object> sendFuture = txContext.sendBatchedModifications();
assertEquals(2, limiter.availablePermits());
BatchedModifications msg = kit.expectMsgClass(BatchedModifications.class);
assertEquals(2, msg.getModifications().size());
assertEquals(1, msg.getTotalMessagesSent());
sendReply(new Failure(new NullPointerException()));
- assertFuture(future, new OnComplete<Object>() {
+ assertFuture(sendFuture, new OnComplete<Object>() {
@Override
public void onComplete(final Throwable failure, final Object success) {
assertTrue(failure instanceof NullPointerException);
assertEquals(4, limiter.availablePermits());
// The transaction has failed, no throttling should occur
- txContext.executeModification(DELETE);
+ txContext.executeModification(DELETE, null);
assertEquals(4, limiter.availablePermits());
// Executing a read should result in immediate failure
final SettableFuture<Boolean> readFuture = SettableFuture.create();
- txContext.executeRead(new DataExists(), readFuture);
+ txContext.executeRead(new DataExists(), readFuture, null);
assertTrue(readFuture.isDone());
try {
readFuture.get();
}
});
- future = txContext.directCommit();
+ final Future<Object> commitFuture = txContext.directCommit(null);
msg = kit.expectMsgClass(BatchedModifications.class);
// Modification should have been thrown away by the dropped transmit induced by executeRead()
assertTrue(msg.isReady());
assertEquals(2, msg.getTotalMessagesSent());
sendReply(new Failure(new IllegalStateException()));
- assertFuture(future, new OnComplete<Object>() {
+ assertFuture(commitFuture, new OnComplete<Object>() {
@Override
public void onComplete(final Throwable failure, final Object success) {
assertTrue(failure instanceof IllegalStateException);
}
});
- kit.expectNoMsg();
+ kit.expectNoMessage();
}
/**
*/
@Test
public void testLimiterOnOverflowFailure() throws TimeoutException, InterruptedException {
- txContext.executeModification(DELETE);
- txContext.executeModification(DELETE);
- txContext.executeModification(DELETE);
- txContext.executeModification(DELETE);
+ txContext.executeModification(DELETE, null);
+ txContext.executeModification(DELETE, null);
+ txContext.executeModification(DELETE, null);
+ txContext.executeModification(DELETE, null);
assertEquals(0, limiter.availablePermits());
- txContext.executeModification(DELETE);
+ txContext.executeModification(DELETE, null);
// Last acquire should have failed ...
assertEquals(0, limiter.availablePermits());
- Future<Object> future = txContext.sendBatchedModifications();
+ final Future<Object> future = txContext.sendBatchedModifications();
assertEquals(0, limiter.availablePermits());
BatchedModifications msg = kit.expectMsgClass(BatchedModifications.class);
}
});
- kit.expectNoMsg();
+ kit.expectNoMessage();
}
private void sendReply(final Object message) {