mongodb - mongodb allanbank非同期ドライバーコールバックが2回呼び出される

Question

呼び出しにバインドされた単純なコールバックがありfindAsyncます。データベース内のデータが静的であっても、数回のリクエストごとにエラーが発生します。

いくつかの簡単なデバッグは、コールバックが常に 2 回呼び出されていることを示しています。アプリが失敗するケースはnull MongoIterator<Document>、コールバックに渡されたことが原因です。もちろん、データの準備が整ったとき (または例外が発生したとき) にコールバックが 1 回しかないと予想していました。

これは予想される動作ですか？クエリが完了したときにコールバックが 1 回だけ呼び出されるようにするためにできることはありますか?

コード スニペットは次のとおりです。

collection.findAsync(
    [
        callback: { MongoIterator<Document> v ->
            List data = []
            try {
                while(v.hasNext()) {
                    data.add(docToJson(v.next()))
                }
            } finally {
                if (v != null) v.close()
            }
            sendReply([ status: 'ok', data: data ])
        },
        exception: { Throwable t ->
            sendReply([ status: 'error', message: t.message ])
        }
    ] as Callback<MongoIterator<Document>>,
    find
)

スタック トレースは次のとおりです。

Unexpected MongoDB Connection closed: Auth(MongoDB(43026-->localhost/127.0.0.1:27017)). Will try to reconnect.
Reconnected to localhost/127.0.0.1:27017
Exception in thread "MongoDB 43026<--localhost/127.0.0.1:27017" java.lang.NullPointerException: Cannot invoke method hasNext() on null object
    at org.codehaus.groovy.runtime.NullObject.invokeMethod(NullObject.java:77)
    at org.codehaus.groovy.runtime.callsite.PogoMetaClassSite.call(PogoMetaClassSite.java:45)
    at org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall(CallSiteArray.java:45)
    at org.codehaus.groovy.runtime.callsite.NullCallSite.call(NullCallSite.java:32)
    at org.codehaus.groovy.runtime.callsite.CallSiteArray.defaultCall(CallSiteArray.java:45)
    at org.codehaus.groovy.runtime.callsite.PogoMetaClassSite.call(PogoMetaClassSite.java:54)
    at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:112)
    at mongoAsync$_run_closure2_closure6.doCall(mongoAsync.groovy:126)
    at sun.reflect.GeneratedMethodAccessor54.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:601)
    at org.codehaus.groovy.reflection.CachedMethod.invoke(CachedMethod.java:90)
    at groovy.lang.MetaMethod.doMethodInvoke(MetaMethod.java:233)
    at org.codehaus.groovy.runtime.metaclass.ClosureMetaClass.invokeMethod(ClosureMetaClass.java:272)
    at groovy.lang.MetaClassImpl.invokeMethod(MetaClassImpl.java:909)
    at groovy.lang.Closure.call(Closure.java:411)
    at org.codehaus.groovy.runtime.ConvertedMap.invokeCustom(ConvertedMap.java:50)
    at org.codehaus.groovy.runtime.ConversionHandler.invoke(ConversionHandler.java:81)
    at com.sun.proxy.$Proxy14.callback(Unknown Source)
    at com.allanbank.mongodb.client.AbstractReplyCallback.handle(AbstractReplyCallback.java:82)
    at com.allanbank.mongodb.client.AbstractValidatingReplyCallback.callback(AbstractValidatingReplyCallback.java:72)
    at com.allanbank.mongodb.client.AbstractValidatingReplyCallback.callback(AbstractValidatingReplyCallback.java:33)
    at com.allanbank.mongodb.connection.message.ReplyHandler.reply(ReplyHandler.java:77)
    at com.allanbank.mongodb.connection.socket.SocketConnection.reply(SocketConnection.java:560)
    at com.allanbank.mongodb.connection.socket.SocketConnection$ReceiveRunnable.receiveOne(SocketConnection.java:735)
    at com.allanbank.mongodb.connection.socket.SocketConnection$ReceiveRunnable.run(SocketConnection.java:683)
    at java.lang.Thread.run(Thread.java:722)