message: Update the max time op event timer when the dsn moves forward
diff: @@ -515,6 +515,12 @@ export class DeliLambda extends EventEmitter implements IPartitionLambda {
  }
  this.durableSequenceNumber = dsn;
  +
  + if (this.serviceConfiguration.deli.opEvent.enable) {
  + // since the dsn updated, ops were reliably stored
  + // we can safely restart the MaxTime timer
  + this.updateOpMaxTimeTimer();
  + }
  }
  break;
  @@ -869,6 +875,10 @@ export class DeliLambda extends EventEmitter implements IPartitionLambda {
  }
  }
  + /**
  + * Reset the op event idle timer
  + * Called after a kafka message is processed
  + */
  private updateOpIdleTimer() {
  const idleTime = this.serviceConfiguration.deli.opEvent.idleTime;
  if (idleTime === undefined) {
  @@ -889,6 +899,10 @@ export class DeliLambda extends EventEmitter implements IPartitionLambda {
  }
  }
  + /**
  + * Resets the op event MaxTime timer
  + * Called after an opEvent is emitted or when the dsn is updated
  + */
  private updateOpMaxTimeTimer() {
  const maxTime = this.serviceConfiguration.deli.opEvent.maxTime;
  if (maxTime === undefined) {
  @@ -909,6 +923,10 @@ export class DeliLambda extends EventEmitter implements IPartitionLambda {
  }
  }
  + /**
  + * Emits an opEvent based for the provided type
  + * Also resets the MaxTime timer
  + */
  private emitOpEvent(type: OpEventType) {
  if (this.messagesSinceLastOpEvent === 0) {
  // no need to emit since no messages were handled since last time
  