diff --git a/lib/src/main/scala/net/kemitix/thorp/lib/LocalFileSystem.scala b/lib/src/main/scala/net/kemitix/thorp/lib/LocalFileSystem.scala
index 774541b..d69681e 100644
--- a/lib/src/main/scala/net/kemitix/thorp/lib/LocalFileSystem.scala
+++ b/lib/src/main/scala/net/kemitix/thorp/lib/LocalFileSystem.scala
@@ -78,7 +78,10 @@ object LocalFileSystem extends LocalFileSystem {
                                  actionCounter,
                                  bytesCounter,
                                  eventsRef)
-      _      <- MessageChannel.pointToPoint(keySender)(keyReceiver).runDrain
+      parallel <- Config.parallel
+      _ <- MessageChannel
+        .pointToPointPar(parallel)(keySender)(keyReceiver)
+        .runDrain
       events <- eventsRef.get
     } yield events