test class moved into a different module

Author: mneedham

consumer/pom.xml

@@ -23,6 +23,7 @@
             <artifactId>neo4j-streams-common</artifactId>
             <version>3.5.0</version>
         </dependency>
+
     </dependencies>
 
 </project>

pom.xml

@@ -165,6 +165,13 @@
             <version>${testcontainers.version}</version>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>org.neo4j.community</groupId>
+            <artifactId>it-test-support</artifactId>
+            <version>${neo4j.version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
     <build>

producer/pom.xml

@@ -23,6 +23,7 @@
             <artifactId>neo4j-streams-common</artifactId>
             <version>3.5.0</version>
         </dependency>
+        
     </dependencies>
 
 </project>

producer/src/main/kotlin/streams/StreamsExtensionFactory.kt

@@ -1,6 +1,7 @@
 package streams
 
-import org.neo4j.kernel.AvailabilityGuard
+import org.neo4j.kernel.availability.AvailabilityGuard
+import org.neo4j.kernel.availability.AvailabilityListener
 import org.neo4j.kernel.configuration.Config
 import org.neo4j.kernel.extension.ExtensionType
 import org.neo4j.kernel.extension.KernelExtensionFactory
@@ -56,7 +57,7 @@ class StreamsEventRouterLifecycle(val db: GraphDatabaseAPI, val streamHandler: S
             streamsConstraintsService = StreamsConstraintsService(db, streamsEventRouterConfiguration.schemaPollingInterval)
             txHandler = StreamsTransactionEventHandler(streamHandler, streamsConstraintsService, streamsEventRouterConfiguration)
             db.registerTransactionEventHandler(txHandler)
-            availabilityGuard.addListener(object: AvailabilityGuard.AvailabilityListener {
+            availabilityGuard.addListener(object: AvailabilityListener {
                 override fun unavailable() {}
 
                 override fun available() {

producer/src/test/kotlin/streams/integrations/KafkaEventRouterIT.kt

@@ -7,10 +7,7 @@ import org.apache.kafka.clients.consumer.KafkaConsumer
 import org.apache.kafka.common.serialization.ByteArrayDeserializer
 import org.apache.kafka.common.serialization.StringDeserializer
 import org.junit.*
-import org.junit.Assume.assumeNotNull
-import org.junit.Assume.assumeTrue
 import org.junit.rules.TestName
-import org.neo4j.graphdb.schema.ConstraintType
 import org.neo4j.kernel.impl.proc.Procedures
 import org.neo4j.kernel.internal.GraphDatabaseAPI
 import org.neo4j.test.TestGraphDatabaseFactory