- final SchemaSourceRegistration<T> reg = register(source.getIdentifier());
- final FinalizablePhantomReference<T> ref = new FinalizablePhantomReference<>(source, queue) {
- @Override
- public void finalizeReferent() {
- reg.close();
- regs.remove(this);
- }
- };
+ // Make the source available
+ cache.put(srcId, source);
+ final var reg = register(srcId);