Revision 46821
Added by Alessia Bardi about 7 years ago
| MongoMDStore.java | ||
|---|---|---|
| 137 | 137 |
} |
| 138 | 138 |
|
| 139 | 139 |
@Override |
| 140 |
public ResultSetListener<String> deliver(final String from, final String until, final String recordFilter) {
|
|
| 141 |
return deliver(from, until, recordFilter, new SerializeMongoRecord()); |
|
| 140 |
public ResultSetListener<String> deliver(final String from, final String until, final String recordFilter, final boolean noCursorTimeout) {
|
|
| 141 |
return deliver(from, until, recordFilter, new SerializeMongoRecord(), noCursorTimeout);
|
|
| 142 | 142 |
} |
| 143 | 143 |
|
| 144 | 144 |
@Override |
| 145 | 145 |
public ResultSetListener<String> deliverIds(final String from, final String until, final String recordFilter) {
|
| 146 |
return deliver(from, until, recordFilter, new SerializeMongoRecordId()); |
|
| 146 |
return deliver(from, until, recordFilter, new SerializeMongoRecordId(), false);
|
|
| 147 | 147 |
} |
| 148 | 148 |
|
| 149 |
public ResultSetListener<String> deliver(final String from, final String until, final String recordFilter, final Function<DBObject, String> serializer) {
|
|
| 149 |
public ResultSetListener<String> deliver(final String from, final String until, final String recordFilter, final Function<DBObject, String> serializer, boolean noCursorTimeout) {
|
|
| 150 | 150 |
try {
|
| 151 | 151 |
ensureIndices(); |
| 152 | 152 |
final Pattern filter = (recordFilter != null) && (recordFilter.length() > 0) ? Pattern.compile(recordFilter, Pattern.MULTILINE) : null; |
| 153 | 153 |
|
| 154 |
return new MongoResultSetListener(collection, filter, serializer); |
|
| 154 |
return new MongoResultSetListener(collection, filter, serializer, noCursorTimeout);
|
|
| 155 | 155 |
} catch (Throwable e) {
|
| 156 | 156 |
throw new RuntimeException(e); |
| 157 | 157 |
} |
Also available in: Unified diff
New method to disable cursor timeout when reading from mdstore