Revision 50679
Added by Alessia Bardi about 6 years ago
MongoResultSetListener.java | ||
---|---|---|
32 | 32 |
|
33 | 33 |
private Bson query; |
34 | 34 |
|
35 |
public MongoResultSetListener(final MongoCollection<DBObject> collection, final Long from, final Long until, final Pattern filter, final Function<DBObject, String> serializer, final int batchSize) |
|
35 |
public MongoResultSetListener(final MongoCollection<DBObject> collection, final Long from, final Long until, final Pattern filter, final Function<DBObject, String> serializer, final int batchSize, final boolean noCursorTimeout)
|
|
36 | 36 |
throws MDStoreServiceException { |
37 | 37 |
this.collection = collection; |
38 | 38 |
this.serializer = serializer; |
39 | 39 |
this.batchSize = batchSize; |
40 | 40 |
this.query = query(from, until, filter); |
41 |
createCursor(); |
|
41 |
createCursor(noCursorTimeout);
|
|
42 | 42 |
} |
43 | 43 |
|
44 | 44 |
private void createCursor(final boolean noCursorTimeout) throws MDStoreServiceException { |
Also available in: Unified diff
re-introduced the "noCursorTimeout" option that was overridden by the merge from trunk