Add constructor with connection string

jet · Nov 18, 2022 · 3abd627 · 3abd627
1 parent 7828420
commit 3abd627
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/Propulsion.MessageDb/MessageDbSource.fs b/src/Propulsion.MessageDb/MessageDbSource.fs
@@ -88,6 +88,9 @@ type MessageDbSource
                 let! b = Impl.readBatch batchSize reader req
                 yield sw.Elapsed, b }),
             string)
+    new (log, statsInterval, connectionString, batchSize, tailSleepInterval, checkpoints, sink, categories, ?startFromTail, ?sourceId) =
+        MessageDbSource(log, statsInterval, MessageDbCategoryClient(connectionString),
+                        batchSize, tailSleepInterval, checkpoints, sink, categories, ?startFromTail=startFromTail, ?sourceId=sourceId)
 
     abstract member ListTranches : unit -> Async<Propulsion.Feed.TrancheId array>
     default _.ListTranches() = async { return categories |> Array.map TrancheId.parse }