diff --git a/community/cypher/acceptance-spec-suite/src/test/java/org/neo4j/internal/cypher/acceptance/TestResourceProcedure.java b/community/cypher/acceptance-spec-suite/src/test/java/org/neo4j/internal/cypher/acceptance/TestResourceProcedure.java
new file mode 100644
index 0000000000000..bee468d25b2df
--- /dev/null
+++ b/community/cypher/acceptance-spec-suite/src/test/java/org/neo4j/internal/cypher/acceptance/TestResourceProcedure.java
@@ -0,0 +1,174 @@
+/*
+ * Copyright (c) 2002-2018 "Neo Technology,"
+ * Network Engine for Objects in Lund AB [http://neotechnology.com]
+ *
+ * This file is part of Neo4j.
+ *
+ * Neo4j is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+package org.neo4j.internal.cypher.acceptance;
+
+import java.util.Iterator;
+import java.util.stream.Stream;
+import java.util.stream.StreamSupport;
+
+import org.neo4j.graphdb.GraphDatabaseService;
+import org.neo4j.kernel.impl.proc.ComponentRegistry;
+import org.neo4j.procedure.Context;
+import org.neo4j.procedure.Description;
+import org.neo4j.procedure.Mode;
+import org.neo4j.procedure.Name;
+import org.neo4j.procedure.Procedure;
+import org.neo4j.procedure.UserFunction;
+
+public class TestResourceProcedure
+{
+ public static abstract class SimulateFailureBaseException extends RuntimeException
+ {
+ }
+
+ public static class SimulateFailureException extends SimulateFailureBaseException
+ {
+ }
+
+ public static class SimulateFailureOnCloseException extends SimulateFailureBaseException
+ {
+ }
+
+ @Context
+ public GraphDatabaseService db;
+
+ @Context
+ public Counters counters;
+
+ public static class Counters
+ {
+ public int closeCountTestResourceProcedure = 0;
+ public int closeCountTestFailingResourceProcedure = 0;
+ public int closeCountTestOnCloseFailingResourceProcedure = 0;
+
+ public int openCountTestResourceProcedure = 0;
+ public int openCountTestFailingResourceProcedure = 0;
+ public int openCountTestOnCloseFailingResourceProcedure = 0;
+
+ public int liveCountTestResourceProcedure()
+ {
+ return openCountTestResourceProcedure - closeCountTestResourceProcedure;
+ }
+
+ public int liveCountTestFailingResourceProcedure()
+ {
+ return openCountTestFailingResourceProcedure - closeCountTestFailingResourceProcedure;
+ }
+
+ public int liveCountTestOnCloseFailingResourceProcedure()
+ {
+ return openCountTestOnCloseFailingResourceProcedure - closeCountTestOnCloseFailingResourceProcedure;
+ }
+
+ public void reset()
+ {
+ closeCountTestResourceProcedure = 0;
+ closeCountTestFailingResourceProcedure = 0;
+ closeCountTestOnCloseFailingResourceProcedure = 0;
+ openCountTestResourceProcedure = 0;
+ openCountTestFailingResourceProcedure = 0;
+ openCountTestOnCloseFailingResourceProcedure = 0;
+ }
+ }
+
+ public static ComponentRegistry.Provider countersProvider(Counters counters1)
+ {
+ return context -> counters1;
+ }
+
+ public class Output
+ {
+ public Long value;
+
+ public Output( Long value )
+ {
+ this.value = value;
+ }
+ }
+
+ @Procedure( name = "org.neo4j.test.testResourceProcedure", mode = Mode.READ )
+ @Description( "Returns a stream of integers from 1 to the given argument" )
+ public Stream