fixed closing AQL cursor (#534)

Author: rashtao

Diff for: core/src/main/java/com/arangodb/internal/ArangoDatabaseImpl.java

@@ -202,8 +202,9 @@ public <T> ArangoCursor<T> cursor(final String cursorId, final Class<T> type, fi
     private <T> ArangoCursor<T> createCursor(
             final CursorEntity<T> result,
             final Class<T> type,
-            final AqlQueryOptions options,
+            final AqlQueryOptions opts,
             final HostHandle hostHandle) {
+        AqlQueryOptions options = opts != null ? opts : new AqlQueryOptions();
 
         final ArangoCursorExecute<T> execute = new ArangoCursorExecute<T>() {
             @Override
@@ -223,8 +224,7 @@ public void close(final String id) {
                 }
             }
         };
-
-        return new ArangoCursorImpl<>(execute, type, result);
+        return new ArangoCursorImpl<>(execute, type, result, options.getAllowRetry());
     }
 
     @Override

Diff for: core/src/main/java/com/arangodb/internal/cursor/ArangoCursorImpl.java

@@ -44,14 +44,14 @@ public class ArangoCursorImpl<T> implements ArangoCursor<T> {
     private final boolean allowRetry;
 
     public ArangoCursorImpl(final ArangoCursorExecute<T> execute,
-                            final Class<T> type, final CursorEntity<T> result) {
+                            final Class<T> type, final CursorEntity<T> result, final Boolean allowRetry) {
         super();
         this.execute = execute;
         this.type = type;
         id = result.getId();
         pontentialDirtyRead = result.isPotentialDirtyRead();
         iterator = new ArangoCursorIterator<>(id, execute, result);
-        this.allowRetry = result.getNextBatchId() != null;
+        this.allowRetry = Boolean.TRUE.equals(allowRetry);
     }
 
     @Override