Revision 49676
Added by Sandro La Bruzzo over 6 years ago
| ResolverMDStorePlugin.java | ||
|---|---|---|
| 24 | 24 |
import java.util.ArrayList; |
| 25 | 25 |
import java.util.List; |
| 26 | 26 |
import java.util.Map; |
| 27 |
import java.util.Objects; |
|
| 27 | 28 |
import java.util.concurrent.*; |
| 28 | 29 |
|
| 29 | 30 |
import static com.mongodb.client.model.Filters.eq; |
| ... | ... | |
| 65 | 66 |
try {
|
| 66 | 67 |
|
| 67 | 68 |
final String id = params.get("mdStoreId");
|
| 69 |
final boolean offline = "true".equals(params.get("offline"));
|
|
| 68 | 70 |
|
| 69 | 71 |
int numberOfThreads = 4; |
| 70 | 72 |
|
| ... | ... | |
| 117 | 119 |
final long ts = System.currentTimeMillis(); |
| 118 | 120 |
|
| 119 | 121 |
for (int i = 0; i < numberOfThreads; i++) {
|
| 120 |
final RecordResolver resolver = recordResolverFactory.createResolver(ts, queue, resolvedRecord, resolverSerializer, pluginResolver); |
|
| 122 |
final RecordResolver resolver = recordResolverFactory.createResolver(ts, queue, resolvedRecord, resolverSerializer, pluginResolver, offline);
|
|
| 121 | 123 |
responses.add(executor.submit(resolver)); |
| 122 | 124 |
} |
| 123 | 125 |
|
Also available in: Unified diff
Changed Crossref to use dump on mongoDB