Add CancellationToken support to all driver calls

README.md

@@ -29,16 +29,19 @@ Both journal and snapshot store share the same configuration keys (however they
 ```hocon
 akka.persistence {
 	journal {
-	plugin = "akka.persistence.journal.mongodb"
+		plugin = "akka.persistence.journal.mongodb"
 		mongodb {
 			# qualified type name of the MongoDb persistence journal actor
 			class = "Akka.Persistence.MongoDb.Journal.MongoDbJournal, Akka.Persistence.MongoDb"
 
 			# connection string used for database access
 			connection-string = ""
 
+			# transaction
+			use-write-transaction = off
+
 			# should corresponding journal table's indexes be initialized automatically
-			auto-initialize = off
+			auto-initialize = on
 
 			# dispatcher used to drive journal actor
 			plugin-dispatcher = "akka.actor.default-dispatcher"
@@ -55,20 +58,29 @@ akka.persistence {
 			#
 			# NOTE: this will likely break features such as Akka.Cluster.Sharding, IActorRef serialization, AtLeastOnceDelivery, and more.
 			legacy-serialization = off
+
+			# Per-call timeout setting - Journal will err on the side of caution and fail calls that take longer than this
+			# to complete. This is to prevent the journal from blocking indefinitely if the database is slow or unresponsive.
+			# If you experience frequent failures due to timeouts, you may want to increase this value.
+			# Default: 10 seconds
+			call-timeout = 10s
 		}
 	}
 
 	snapshot-store {
-	plugin = "akka.persistence.snapshot-store.mongodb"
+		plugin = "akka.persistence.snapshot-store.mongodb"
 		mongodb {
 			# qualified type name of the MongoDB persistence snapshot actor
 			class = "Akka.Persistence.MongoDb.Snapshot.MongoDbSnapshotStore, Akka.Persistence.MongoDb"
 
 			# connection string used for database access
 			connection-string = ""
 
+			# transaction
+			use-write-transaction = off
+
 			# should corresponding snapshot's indexes be initialized automatically
-			auto-initialize = off
+			auto-initialize = on
 
 			# dispatcher used to drive snapshot storage actor
 			plugin-dispatcher = "akka.actor.default-dispatcher"
@@ -82,8 +94,36 @@ akka.persistence {
 			#
 			# NOTE: this will likely break features such as Akka.Cluster.Sharding, IActorRef serialization, AtLeastOnceDelivery, and more.
 			legacy-serialization = off
+
+      # Per-call timeout setting - Journal will err on the side of caution and fail calls that take longer than this
+      # to complete. This is to prevent the journal from blocking indefinitely if the database is slow or unresponsive.
+      # If you experience frequent failures due to timeouts, you may want to increase this value.
+      # Default: 10 seconds
+      call-timeout = 10s
 		}
 	}
+
+    query {
+        mongodb {
+            # Implementation class of the EventStore ReadJournalProvider
+            class = "Akka.Persistence.MongoDb.Query.MongoDbReadJournalProvider, Akka.Persistence.MongoDb"
+
+            # Absolute path to the write journal plugin configuration entry that this 
+            # query journal will connect to. 
+            # If undefined (or "") it will connect to the default journal as specified by the
+            # akka.persistence.journal.plugin property.
+            write-plugin = ""
+
+            # The SQL write journal is notifying the query side as soon as things
+            # are persisted, but for efficiency reasons the query side retrieves the events 
+            # in batches that sometimes can be delayed up to the configured `refresh-interval`.
+            refresh-interval = 3s
+
+            # How many events to fetch in one query (replay) and keep buffered until they
+            # are delivered downstreams.
+            max-buffer-size = 500
+        }
+    }
 }
 ```
 

src/Akka.Persistence.MongoDb.Tests/MongoDbSettingsSpec.cs

@@ -6,6 +6,7 @@
 //-----------------------------------------------------------------------
 
 using FluentAssertions;
+using FluentAssertions.Extensions;
 using Xunit;
 
 namespace Akka.Persistence.MongoDb.Tests
@@ -23,6 +24,7 @@ public void Mongo_JournalSettings_must_have_default_values()
             mongoPersistence.JournalSettings.Collection.Should().Be("EventJournal");
             mongoPersistence.JournalSettings.MetadataCollection.Should().Be("Metadata");
             mongoPersistence.JournalSettings.LegacySerialization.Should().BeFalse();
+            mongoPersistence.JournalSettings.CallTimeout.Should().Be(10.Seconds());
         }
 
         [Fact]
@@ -34,6 +36,7 @@ public void Mongo_SnapshotStoreSettingsSettings_must_have_default_values()
             mongoPersistence.SnapshotStoreSettings.AutoInitialize.Should().BeTrue();
             mongoPersistence.SnapshotStoreSettings.Collection.Should().Be("SnapshotStore");
             mongoPersistence.SnapshotStoreSettings.LegacySerialization.Should().BeFalse();
+            mongoPersistence.SnapshotStoreSettings.CallTimeout.Should().Be(10.Seconds());
         }
     }
 }

src/Akka.Persistence.MongoDb/Akka.Persistence.MongoDb.csproj

@@ -3,6 +3,7 @@
 
   <PropertyGroup>
     <TargetFrameworks>$(NetStandardLibVersion)</TargetFrameworks>
+    <LangVersion>latest</LangVersion>
   </PropertyGroup>
 
   <ItemGroup>