sleep(3);
continue;
}
- if ($this->poolHasDomain($p->person()->email) > $this->max_to_domain) {
+ $email = $p->person() ? $p->person()->email : $p->to_email;
+
+ if ($this->poolHasDomain($email) > $this->max_to_domain) {
if ($pushed === false) {
// we only try once to requeue..
}
- $this->run($p->id,$p->person()->email);
+ $this->run($p->id,$email);