D-Net

import org.bson.conversions.Bson;

import org.springframework.beans.factory.annotation.Autowired;

import java.util.concurrent.*;

import static com.mongodb.client.model.Filters.eq;

            final long ts = System.currentTimeMillis();

				final RecordResolver resolver = recordResolverFactory.createResolver(ts, queue, resolvedRecord, resolverSerializer, pluginResolver, offline);

				responses.add(executor.submit(resolver));

			}