WriteBatchingTransactionService implements TransactionService { @CheckForNull @Override public Long get(long startTimestamp) { return delegate.get(startTimestamp); } private  WriteBatchingTransactionService(
            EncodingTransactionService delegate, DisruptorAutobatcher<TimestampPair, Void> autobatcher); static TransactionService create(EncodingTransactionService delegate); @CheckForNull @Override Long get(long startTimestamp); @Override Map<Long, Long> get(Iterable<Long> startTimestamps); @Override ListenableFuture<Long> getAsync(long startTimestamp); @Override ListenableFuture<Map<Long, Long>> getAsync(Iterable<Long> startTimestamps); @Override void putUnlessExists(long startTimestamp, long commitTimestamp); @Override void close();  }
@Test public void getsValuesFromUnderlying() { when(mockTransactionService.get(anyLong())).thenReturn(5L); assertThat(writeBatchingTransactionService.get(3L)).isEqualTo(5L); verify(mockTransactionService).get(3L); }