Update RedeliveryActors.scala

Author: MohamedEL59

core/src/main/scala/com.softwaremill.kmq/redelivery/RedeliveryActors.scala

@@ -9,11 +9,17 @@ import com.typesafe.scalalogging.StrictLogging
 import scala.concurrent.Await
 import scala.concurrent.duration._
 
+import scala.collection.JavaConverters._
+
 object RedeliveryActors extends StrictLogging {
   def start(clients: KafkaClients, config: KmqConfig): Closeable = {
+    start(clients, config)
+  }
+
+  def start(clients: KafkaClients, config: KmqConfig, extraConfig: Option[java.util.Map[String, Object]] = None): Closeable = {
     val system = ActorSystem("kmq-redelivery")
 
-    val consumeMakersActor = system.actorOf(Props(new ConsumeMarkersActor(clients, config)), "consume-markers-actor")
+    val consumeMakersActor = system.actorOf(Props(new ConsumeMarkersActor(clients, config, extraConfig)), "consume-markers-actor")
     consumeMakersActor ! DoConsume
 
     logger.info("Started redelivery actors")