Fix the unit test build error

lensesio · Nov 2, 2023 · e749225 · e749225
1 parent 3fb8bd4
commit e749225
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...test/scala/com/datamountaineer/streamreactor/connect/redis/sink/writer/RedisSslTest.scala b/...test/scala/com/datamountaineer/streamreactor/connect/redis/sink/writer/RedisSslTest.scala
@@ -15,6 +15,7 @@
  */
 package com.datamountaineer.streamreactor.connect.redis.sink.writer
 
+import com.datamountaineer.streamreactor.connect.redis.sink.JedisClientBuilder
 import com.datamountaineer.streamreactor.connect.redis.sink.config.RedisConfig
 import com.datamountaineer.streamreactor.connect.redis.sink.config.RedisConfigConstants
 import com.datamountaineer.streamreactor.connect.redis.sink.config.RedisSinkSettings
@@ -106,8 +107,7 @@ class RedisSslTest extends AnyWordSpec with Matchers with BeforeAndAfterAll with
       val config   = RedisConfig(map.asJava)
       val settings = RedisSinkSettings(config)
 
-      val writer = new RedisCache(settings)
-      writer.createClient(settings)
+      val writer = new RedisCache(settings, JedisClientBuilder.createClient(settings))
 
       val props = System.getProperties
       props.containsKey("javax.net.ssl.keyStorePassword") shouldBe true
@@ -150,7 +150,7 @@ class RedisSslTest extends AnyWordSpec with Matchers with BeforeAndAfterAll with
         val props     = (baseProps + (RedisConfigConstants.KCQL_CONFIG -> QUERY_ALL)).asJava
         val config    = RedisConfig(props)
         val settings  = RedisSinkSettings(config)
-        val writer    = new RedisCache(settings)
+        val writer    = new RedisCache(settings, JedisClientBuilder.createClient(settings))
 
         val childSchema = SchemaBuilder.struct().name("com.example.Child")
           .field("firstName", Schema.STRING_SCHEMA)