'max' => 100,
),
);
-
+ /**
+ * @var $nice_level Unix 'nice' level to stop it jamming server up.
+ */
var $nice_level = false;
+ /**
+ * @var $max_pool_size maximum runners to start at once.
+ */
var $max_pool_size = 10;
+ /**
+ * @var $max_to_domain maximum connections to make to a single domain
+ */
+ var $max_to_domain = 10;
var $table = 'core_notify';
var $target = 'Core/NotifySend';
sleep(3);
continue;
}
- if ($this->poolHasDomain($p->person_id_email)) {
+ if ($this->poolHasDomain($p->person_id_email) > $this->max_to_domain) {
if ($pushed === false) {
// we only try once to requeue..
foreach($requeue as $p) {
$pp = clone($p);
- $p->act_when = strtotime($p->act_when . ' + 1 MINUTE');
+ $p->act_when = $p->sqlValue('NOW + INTERVAL 1 MINUTE');
$p->update($pp);
}