Fix parameter name

akkadotnet · Feb 9, 2021 · 1397850 · 1397850
1 parent e5ad251
commit 1397850
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/contrib/persistence/Akka.Persistence.Sql.Common/Journal/BatchingSqlJournal.cs b/src/contrib/persistence/Akka.Persistence.Sql.Common/Journal/BatchingSqlJournal.cs
@@ -994,7 +994,7 @@ protected virtual async Task<long> ReadHighestSequenceNr(string persistenceId, T
             command.CommandText = HighestSequenceNrSql;
 
             command.Parameters.Clear();
-            AddParameter(command, "PersistenceId", DbType.String, persistenceId);
+            AddParameter(command, "@PersistenceId", DbType.String, persistenceId);
 
             var result = await command.ExecuteScalarAsync();
             var highestSequenceNr = result is long ? Convert.ToInt64(result) : 0L;