File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed
driver/src/main/java/org/neo4j/driver/internal/cursor Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change 31
31
import org .neo4j .driver .Query ;
32
32
import org .neo4j .driver .Record ;
33
33
import org .neo4j .driver .Value ;
34
+ import org .neo4j .driver .exceptions .ClientException ;
34
35
import org .neo4j .driver .exceptions .TransactionNestingException ;
35
36
import org .neo4j .driver .internal .DatabaseBookmark ;
36
37
import org .neo4j .driver .internal .InternalRecord ;
@@ -166,6 +167,11 @@ public void onError(Throwable throwable) {
166
167
runnable .run ();
167
168
}
168
169
170
+ @ Override
171
+ public void onIgnored () {
172
+ onError (new ClientException ("The message has been ignored by the server possibly for a previous failure" ));
173
+ }
174
+
169
175
@ Override
170
176
public void onRecord (Value [] fields ) {
171
177
var record = new InternalRecord (runSummary .keys (), fields );
You can’t perform that action at this time.
0 commit comments