Skip to content

Commit

Permalink
Fixed approvals
Browse files Browse the repository at this point in the history
  • Loading branch information
IgorFedchenko committed Feb 10, 2021
1 parent 010e6d2 commit 5ee17c1
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,6 @@ namespace Akka.Persistence.Sql.Common.Journal
protected void AddParameter(System.Data.Common.DbCommand command, string parameterName, System.Data.DbType parameterType, object value) { }
protected abstract System.Data.Common.DbCommand CreateCommand(System.Data.Common.DbConnection connection);
public virtual System.Threading.Tasks.Task CreateTablesAsync(System.Data.Common.DbConnection connection, System.Threading.CancellationToken cancellationToken) { }
protected virtual void CustomDbParameterSetup(System.Data.Common.DbCommand command, System.Data.Common.DbParameter param) { }
public virtual System.Threading.Tasks.Task DeleteBatchAsync(System.Data.Common.DbConnection connection, System.Threading.CancellationToken cancellationToken, string persistenceId, long toSequenceNr) { }
protected System.Data.Common.DbCommand GetCommand(System.Data.Common.DbConnection connection, string sql) { }
public virtual System.Threading.Tasks.Task InsertBatchAsync(System.Data.Common.DbConnection connection, System.Threading.CancellationToken cancellationToken, Akka.Persistence.Sql.Common.Journal.WriteJournalBatch write) { }
Expand Down Expand Up @@ -104,7 +103,6 @@ namespace Akka.Persistence.Sql.Common.Journal
protected void AddParameter(TCommand command, string paramName, System.Data.DbType dbType, object value) { }
protected void BatchRequest(Akka.Persistence.IJournalRequest message) { }
protected abstract TConnection CreateConnection(string connectionString);
protected virtual void CustomDbParameterSetup(TCommand command, System.Data.Common.DbParameter param) { }
protected virtual System.Threading.Tasks.Task HandleDeleteMessagesTo(Akka.Persistence.DeleteMessagesTo req, TCommand command) { }
protected virtual System.Threading.Tasks.Task HandleReplayAllMessages(Akka.Persistence.Sql.Common.Journal.ReplayAllEvents req, TCommand command) { }
protected virtual System.Threading.Tasks.Task HandleReplayMessages(Akka.Persistence.ReplayMessages req, TCommand command, Akka.Actor.IActorContext context) { }
Expand Down Expand Up @@ -372,7 +370,6 @@ namespace Akka.Persistence.Sql.Common.Snapshot
protected void AddParameter(System.Data.Common.DbCommand command, string parameterName, System.Data.DbType parameterType, object value) { }
protected abstract System.Data.Common.DbCommand CreateCommand(System.Data.Common.DbConnection connection);
public virtual System.Threading.Tasks.Task CreateTableAsync(System.Data.Common.DbConnection connection, System.Threading.CancellationToken cancellationToken) { }
protected virtual void CustomDbParameterSetup(System.Data.Common.DbCommand command, System.Data.Common.DbParameter param) { }
public virtual System.Threading.Tasks.Task DeleteAsync(System.Data.Common.DbConnection connection, System.Threading.CancellationToken cancellationToken, string persistenceId, long sequenceNr, System.Nullable<System.DateTime> timestamp) { }
public virtual System.Threading.Tasks.Task DeleteBatchAsync(System.Data.Common.DbConnection connection, System.Threading.CancellationToken cancellationToken, string persistenceId, long maxSequenceNr, System.DateTime maxTimestamp) { }
protected System.Data.Common.DbCommand GetCommand(System.Data.Common.DbConnection connection, string sql) { }
Expand Down

0 comments on commit 5ee17c1

Please sign in to comment.