@Test public void testGetSequenceNumber() { ExtendedSequenceNumber sn = new ExtendedSequenceNumber("sn"); PreparedCheckpointer checkpointer = new ShardPreparedCheckpointer(sn, null); Assert.assertEquals(sn, checkpointer.pendingCheckpoint()); }
@Override public ExtendedSequenceNumber pendingCheckpoint() { return pendingCheckpointSequenceNumber; }
ShardPreparedCheckpointer implements PreparedCheckpointer { @Override public ExtendedSequenceNumber pendingCheckpoint() { return pendingCheckpointSequenceNumber; } }
ShardPreparedCheckpointer implements PreparedCheckpointer { @Override public ExtendedSequenceNumber pendingCheckpoint() { return pendingCheckpointSequenceNumber; } ShardPreparedCheckpointer(ExtendedSequenceNumber pendingCheckpointSequenceNumber,
                                     RecordProcessorCheckpointer checkpointer); }
ShardPreparedCheckpointer implements PreparedCheckpointer { @Override public ExtendedSequenceNumber pendingCheckpoint() { return pendingCheckpointSequenceNumber; } ShardPreparedCheckpointer(ExtendedSequenceNumber pendingCheckpointSequenceNumber,
                                     RecordProcessorCheckpointer checkpointer); @Override ExtendedSequenceNumber pendingCheckpoint(); @Override void checkpoint(); }
ShardPreparedCheckpointer implements PreparedCheckpointer { @Override public ExtendedSequenceNumber pendingCheckpoint() { return pendingCheckpointSequenceNumber; } ShardPreparedCheckpointer(ExtendedSequenceNumber pendingCheckpointSequenceNumber,
                                     RecordProcessorCheckpointer checkpointer); @Override ExtendedSequenceNumber pendingCheckpoint(); @Override void checkpoint();  }