@Test public void doesNotThrowDependencyExceptionWhenDelegateFailsForSomeOtherReason() { when(delegate.currentTimeMillis()).thenThrow(new RuntimeException("something else happened")); assertThatThrownBy(timelock::currentTimeMillis).isInstanceOf(RuntimeException.class) .isNotInstanceOf(AtlasDbDependencyException.class); }
@Override public long currentTimeMillis() { return executeOnTimeLock(delegate::currentTimeMillis); }
TimeLockClient implements AutoCloseable, TimelockService { @Override public long currentTimeMillis() { return executeOnTimeLock(delegate::currentTimeMillis); } }
TimeLockClient implements AutoCloseable, TimelockService { @Override public long currentTimeMillis() { return executeOnTimeLock(delegate::currentTimeMillis); } @VisibleForTesting  TimeLockClient(TimelockService delegate, CloseableTimestampService timestampService,
            LockRefresher lockRefresher, TimeLockUnlocker unlocker); }
TimeLockClient implements AutoCloseable, TimelockService { @Override public long currentTimeMillis() { return executeOnTimeLock(delegate::currentTimeMillis); } @VisibleForTesting  TimeLockClient(TimelockService delegate, CloseableTimestampService timestampService,
            LockRefresher lockRefresher, TimeLockUnlocker unlocker); static TimeLockClient createDefault(TimelockService timelockService); static TimeLockClient withSynchronousUnlocker(TimelockService timelockService); @Override boolean isInitialized(); @Override long getFreshTimestamp(); @Override long getCommitTimestamp(long startTs, LockToken commitLocksToken); @Override TimestampRange getFreshTimestamps(int numTimestampsRequested); @Override LockImmutableTimestampResponse lockImmutableTimestamp(); @Override List<StartIdentifiedAtlasDbTransactionResponse> startIdentifiedAtlasDbTransactionBatch(int count); @Override long getImmutableTimestamp(); @Override LockResponse lock(LockRequest request); @Override WaitForLocksResponse waitForLocks(WaitForLocksRequest request); @Override Set<LockToken> refreshLockLeases(Set<LockToken> tokens); @Override Set<LockToken> unlock(Set<LockToken> tokens); @Override void tryUnlock(Set<LockToken> tokens); @Override long currentTimeMillis(); @Override void close(); }
TimeLockClient implements AutoCloseable, TimelockService { @Override public long currentTimeMillis() { return executeOnTimeLock(delegate::currentTimeMillis); } @VisibleForTesting  TimeLockClient(TimelockService delegate, CloseableTimestampService timestampService,
            LockRefresher lockRefresher, TimeLockUnlocker unlocker); static TimeLockClient createDefault(TimelockService timelockService); static TimeLockClient withSynchronousUnlocker(TimelockService timelockService); @Override boolean isInitialized(); @Override long getFreshTimestamp(); @Override long getCommitTimestamp(long startTs, LockToken commitLocksToken); @Override TimestampRange getFreshTimestamps(int numTimestampsRequested); @Override LockImmutableTimestampResponse lockImmutableTimestamp(); @Override List<StartIdentifiedAtlasDbTransactionResponse> startIdentifiedAtlasDbTransactionBatch(int count); @Override long getImmutableTimestamp(); @Override LockResponse lock(LockRequest request); @Override WaitForLocksResponse waitForLocks(WaitForLocksRequest request); @Override Set<LockToken> refreshLockLeases(Set<LockToken> tokens); @Override Set<LockToken> unlock(Set<LockToken> tokens); @Override void tryUnlock(Set<LockToken> tokens); @Override long currentTimeMillis(); @Override void close();  }