package com.l7tech.server.transport.email;

import com.l7tech.gateway.common.transport.email.EmailListener;
import java.util.TimerTask;

class f extends TimerTask {
   final EmailListenerBootProcess this$0;

   f(EmailListenerBootProcess var1) {
      this.this$0 = var1;
   }

   @Override
   public void run() {
      for (EmailListener var3 : this.this$0.j.stealSubscriptionsFromDeadNodes(this.this$0.k)) {
         this.this$0.a(var3, true);
      }
   }
}