Skip to content

Commit

Permalink
fix inject of Mailer
Browse files Browse the repository at this point in the history
  • Loading branch information
ssalinas committed Nov 18, 2016
1 parent 8eeb699 commit 4cb16fd
Showing 1 changed file with 5 additions and 4 deletions.
Expand Up @@ -30,6 +30,7 @@
import com.hubspot.singularity.data.SlaveManager; import com.hubspot.singularity.data.SlaveManager;
import com.hubspot.singularity.data.TaskManager; import com.hubspot.singularity.data.TaskManager;
import com.hubspot.singularity.mesos.SingularityMesosModule; import com.hubspot.singularity.mesos.SingularityMesosModule;
import com.hubspot.singularity.smtp.SingularityMailer;
import com.hubspot.singularity.smtp.SingularitySmtpSender; import com.hubspot.singularity.smtp.SingularitySmtpSender;
import com.hubspot.singularity.smtp.SmtpMailer; import com.hubspot.singularity.smtp.SmtpMailer;


Expand All @@ -42,20 +43,20 @@ public class SingularityDisasterDetectionPoller extends SingularityLeaderOnlyPol
private final TaskManager taskManager; private final TaskManager taskManager;
private final SlaveManager slaveManager; private final SlaveManager slaveManager;
private final DisasterManager disasterManager; private final DisasterManager disasterManager;
private final SmtpMailer smtpMailer; private final SingularityMailer mailer;
private final Multiset<Reason> taskLostReasons; private final Multiset<Reason> taskLostReasons;
private final AtomicInteger activeSlavesLost; private final AtomicInteger activeSlavesLost;


@Inject @Inject
public SingularityDisasterDetectionPoller(SingularityConfiguration configuration, TaskManager taskManager, SlaveManager slaveManager, DisasterManager disasterManager, SmtpMailer smtpMailer, public SingularityDisasterDetectionPoller(SingularityConfiguration configuration, TaskManager taskManager, SlaveManager slaveManager, DisasterManager disasterManager, SingularityMailer mailer,
@Named(SingularityMesosModule.TASK_LOST_REASONS_COUNTER) Multiset<Reason> taskLostReasons, @Named(SingularityMesosModule.ACTIVE_SLAVES_LOST_COUNTER) AtomicInteger activeSlavesLost) { @Named(SingularityMesosModule.TASK_LOST_REASONS_COUNTER) Multiset<Reason> taskLostReasons, @Named(SingularityMesosModule.ACTIVE_SLAVES_LOST_COUNTER) AtomicInteger activeSlavesLost) {
super(configuration.getDisasterDetection().getRunEveryMillis(), TimeUnit.MILLISECONDS); super(configuration.getDisasterDetection().getRunEveryMillis(), TimeUnit.MILLISECONDS);
this.configuration = configuration; this.configuration = configuration;
this.disasterConfiguration = configuration.getDisasterDetection(); this.disasterConfiguration = configuration.getDisasterDetection();
this.taskManager = taskManager; this.taskManager = taskManager;
this.slaveManager = slaveManager; this.slaveManager = slaveManager;
this.disasterManager = disasterManager; this.disasterManager = disasterManager;
this.smtpMailer = smtpMailer; this.mailer = mailer;
this.taskLostReasons = taskLostReasons; this.taskLostReasons = taskLostReasons;
this.activeSlavesLost = activeSlavesLost; this.activeSlavesLost = activeSlavesLost;
} }
Expand Down Expand Up @@ -249,7 +250,7 @@ private void queueDisasterEmail(List<SingularityDisasterDataPoint> dataPoints, L
disasterManager.isAutomatedDisabledActionsDisabled() disasterManager.isAutomatedDisabledActionsDisabled()
); );


smtpMailer.sendDisasterMail(data); mailer.sendDisasterMail(data);
} }


} }

0 comments on commit 4cb16fd

Please sign in to comment.