Skip to content

Commit

Permalink
adjust for using typed dispatch
Browse files Browse the repository at this point in the history
  • Loading branch information
sebastianburckhardt committed Dec 22, 2021
1 parent edcb36d commit 76418dc
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -103,5 +103,6 @@ public virtual void Process(ActivityCompleted evt, EffectTracker tracker) { }
public virtual void Process(OffloadDecision evt, EffectTracker tracker) { }
public virtual void Process(SendConfirmed evt, EffectTracker tracker) { }
public virtual void Process(TimerFired evt, EffectTracker tracker) { }
public virtual void Process(RecoveryCompleted evt, EffectTracker tracker) { }
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,10 @@ class RecoveryCompleted : PartitionUpdateEvent
[IgnoreDataMember]
public bool RequiresStateUpdate => (this.NumSessions + this.NumActivities) > 0; // orchestrations and activities must increment the dequeue count

public override void ApplyTo(TrackedObject trackedObject, EffectTracker effects)
{
trackedObject.Process(this, effects);
}

protected override void ExtraTraceInformation(StringBuilder s)
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -73,7 +73,7 @@ public override void OnRecoveryCompleted(RecoveryCompleted evt)
}
}

public void Process(RecoveryCompleted evt, EffectTracker effects)
public override void Process(RecoveryCompleted evt, EffectTracker effects)
{
effects.Partition.Assert(this.Pending.Count == evt.NumActivities);

Expand Down
2 changes: 1 addition & 1 deletion src/DurableTask.Netherite/PartitionState/SessionsState.cs
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ public override void OnRecoveryCompleted(RecoveryCompleted evt)
}
}

public void Process(RecoveryCompleted evt, EffectTracker effects)
public override void Process(RecoveryCompleted evt, EffectTracker effects)
{
effects.Partition.Assert(evt.NumSessions == this.Sessions.Count);

Expand Down

0 comments on commit 76418dc

Please sign in to comment.