@Test public void testCopyInSameDatabase() { ResolverMappingReplicator replicator = new ResolverMappingReplicator(primary, 10); FDBDatabase differentDB = new FDBDatabase(FDBDatabaseFactory.instance(), null); KeySpacePath path = keySpace.path("test-path").add("to").add("replica"); try (FDBRecordContext context = differentDB.openContext()) { LocatableResolver resolverInDifferentDB = new ScopedInterningLayer(differentDB, path.toResolvedPath(context)); replicator.copyTo(resolverInDifferentDB); fail("should throw IllegalArgumentException"); } catch (IllegalArgumentException ex) { assertThat(ex, hasMessageContaining("copy must be within same database")); } }
public void copyTo(LocatableResolver replica) { runner.asyncToSync(FDBStoreTimer.Waits.WAIT_LOCATABLE_RESOLVER_MAPPING_COPY, copyToAsync(replica)); }
ResolverMappingReplicator implements AutoCloseable { public void copyTo(LocatableResolver replica) { runner.asyncToSync(FDBStoreTimer.Waits.WAIT_LOCATABLE_RESOLVER_MAPPING_COPY, copyToAsync(replica)); } }
ResolverMappingReplicator implements AutoCloseable { public void copyTo(LocatableResolver replica) { runner.asyncToSync(FDBStoreTimer.Waits.WAIT_LOCATABLE_RESOLVER_MAPPING_COPY, copyToAsync(replica)); } ResolverMappingReplicator(@Nonnull LocatableResolver primary);  ResolverMappingReplicator(@Nonnull LocatableResolver primary,
                                     final int transactionRowLimit);  ResolverMappingReplicator(@Nonnull LocatableResolver primary,
                                     final int transactionRowLimit,
                                     final long transactionTimeLimitMillis); }
ResolverMappingReplicator implements AutoCloseable { public void copyTo(LocatableResolver replica) { runner.asyncToSync(FDBStoreTimer.Waits.WAIT_LOCATABLE_RESOLVER_MAPPING_COPY, copyToAsync(replica)); } ResolverMappingReplicator(@Nonnull LocatableResolver primary);  ResolverMappingReplicator(@Nonnull LocatableResolver primary,
                                     final int transactionRowLimit);  ResolverMappingReplicator(@Nonnull LocatableResolver primary,
                                     final int transactionRowLimit,
                                     final long transactionTimeLimitMillis); @Override void close(); void copyTo(LocatableResolver replica); CompletableFuture<Void> copyToAsync(@Nonnull final LocatableResolver replica); @Override String toString(); }
ResolverMappingReplicator implements AutoCloseable { public void copyTo(LocatableResolver replica) { runner.asyncToSync(FDBStoreTimer.Waits.WAIT_LOCATABLE_RESOLVER_MAPPING_COPY, copyToAsync(replica)); } ResolverMappingReplicator(@Nonnull LocatableResolver primary);  ResolverMappingReplicator(@Nonnull LocatableResolver primary,
                                     final int transactionRowLimit);  ResolverMappingReplicator(@Nonnull LocatableResolver primary,
                                     final int transactionRowLimit,
                                     final long transactionTimeLimitMillis); @Override void close(); void copyTo(LocatableResolver replica); CompletableFuture<Void> copyToAsync(@Nonnull final LocatableResolver replica); @Override String toString();  }