Revision 49676
Added by Sandro La Bruzzo over 6 years ago
DLIRecordResolverFactory.java | ||
---|---|---|
12 | 12 |
|
13 | 13 |
public class DLIRecordResolverFactory implements RecordResolverFactory { |
14 | 14 |
@Override |
15 |
public RecordResolver createResolver(BlockingQueue<DBObject> queue, MongoCollection<DBObject> outputCollection, ResolverSerializer serializer, List<PIDResolver> pluginResolver) { |
|
15 |
public RecordResolver createResolver(BlockingQueue<DBObject> queue, MongoCollection<DBObject> outputCollection, ResolverSerializer serializer, List<PIDResolver> pluginResolver, boolean offline) {
|
|
16 | 16 |
|
17 |
return createResolver(System.currentTimeMillis(), queue, outputCollection, serializer, pluginResolver); |
|
17 |
return createResolver(System.currentTimeMillis(), queue, outputCollection, serializer, pluginResolver, offline);
|
|
18 | 18 |
} |
19 | 19 |
|
20 | 20 |
@Override |
21 |
public RecordResolver createResolver(long identifier, BlockingQueue<DBObject> queue, MongoCollection<DBObject> outputCollection, ResolverSerializer serializer, List<PIDResolver> pluginResolver) { |
|
21 |
public RecordResolver createResolver(long identifier, BlockingQueue<DBObject> queue, MongoCollection<DBObject> outputCollection, ResolverSerializer serializer, List<PIDResolver> pluginResolver, boolean offline) {
|
|
22 | 22 |
final DLIRecordResolver resolver = new DLIRecordResolver(System.currentTimeMillis()); |
23 | 23 |
resolver.setInputQueue(queue); |
24 | 24 |
resolver.setOutputCollection(outputCollection); |
25 | 25 |
resolver.setSerializer(serializer); |
26 | 26 |
resolver.setPluginResolver(pluginResolver); |
27 |
resolver.setOffline(offline); |
|
27 | 28 |
return resolver; |
28 | 29 |
} |
29 | 30 |
} |
Also available in: Unified diff
Changed Crossref to use dump on mongoDB