@Test public void testResetLargestScn() { transactionalBuffer.registerCommitCallback(TRANSACTION_ID, SCN, Instant.now(), "", (timestamp, smallestScn, commitScn, counter) -> { }); transactionalBuffer.registerCommitCallback(OTHER_TRANSACTION_ID, OTHER_SCN, Instant.now(), "", (timestamp, smallestScn, commitScn, counter) -> { }); assertThat(transactionalBuffer.getLargestScn()).isEqualTo(OTHER_SCN); offsetContext = new OracleOffsetContext(connectorConfig, OTHER_SCN.longValue(), OTHER_SCN.longValue(), null, false, true, new TransactionContext()); transactionalBuffer.commit(OTHER_TRANSACTION_ID, OTHER_SCN, offsetContext, TIMESTAMP, () -> true, MESSAGE); assertThat(transactionalBuffer.getLargestScn()).isEqualTo(OTHER_SCN); transactionalBuffer.resetLargestScn(null); assertThat(transactionalBuffer.getLargestScn()).isEqualTo(BigDecimal.ZERO); transactionalBuffer.resetLargestScn(OTHER_SCN.longValue()); assertThat(transactionalBuffer.getLargestScn()).isEqualTo(OTHER_SCN); }
void resetLargestScn(Long value) { if (value != null) { largestScn = new BigDecimal(value); } else { largestScn = BigDecimal.ZERO; } }
TransactionalBuffer { void resetLargestScn(Long value) { if (value != null) { largestScn = new BigDecimal(value); } else { largestScn = BigDecimal.ZERO; } } }
TransactionalBuffer { void resetLargestScn(Long value) { if (value != null) { largestScn = new BigDecimal(value); } else { largestScn = BigDecimal.ZERO; } } TransactionalBuffer(String logicalName, ErrorHandler errorHandler, TransactionalBufferMetrics metrics, int inCommitQueueCapacity); }
TransactionalBuffer { void resetLargestScn(Long value) { if (value != null) { largestScn = new BigDecimal(value); } else { largestScn = BigDecimal.ZERO; } } TransactionalBuffer(String logicalName, ErrorHandler errorHandler, TransactionalBufferMetrics metrics, int inCommitQueueCapacity); @Override String toString(); }
TransactionalBuffer { void resetLargestScn(Long value) { if (value != null) { largestScn = new BigDecimal(value); } else { largestScn = BigDecimal.ZERO; } } TransactionalBuffer(String logicalName, ErrorHandler errorHandler, TransactionalBufferMetrics metrics, int inCommitQueueCapacity); @Override String toString();  }