mirror of
https://github.com/phpbb/phpbb.git
synced 2025-06-07 20:08:53 +00:00
[ticket/17489] Further queue logic adjustments
Saving queue is not needed if use_queue flag is set to false as in this case the message should be set immediately in the runtime. PHPBB-17487 PHPBB-17489
This commit is contained in:
parent
cebc19f2ed
commit
f9e6385e84
3 changed files with 2 additions and 24 deletions
|
@ -269,23 +269,12 @@ class acp_email
|
||||||
}
|
}
|
||||||
|
|
||||||
$errored = !$messenger_method->send() || $errored;
|
$errored = !$messenger_method->send() || $errored;
|
||||||
|
$messenger_method->save_queue();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
unset($email_list);
|
unset($email_list);
|
||||||
|
|
||||||
if ($use_queue)
|
|
||||||
{
|
|
||||||
/**
|
|
||||||
* @var \phpbb\messenger\method\messenger_interface $messenger_method
|
|
||||||
* @psalm-suppress UndefinedMethod
|
|
||||||
*/
|
|
||||||
foreach ($messenger_collection_iterator as $messenger_method)
|
|
||||||
{
|
|
||||||
$messenger_method->save_queue();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if ($generate_log_entry)
|
if ($generate_log_entry)
|
||||||
{
|
{
|
||||||
if (!empty($usernames))
|
if (!empty($usernames))
|
||||||
|
|
|
@ -223,6 +223,7 @@ class acp_inactive
|
||||||
]);
|
]);
|
||||||
|
|
||||||
$messenger_method->send();
|
$messenger_method->send();
|
||||||
|
$messenger_method->save_queue();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -231,15 +232,6 @@ class acp_inactive
|
||||||
}
|
}
|
||||||
while ($row = $db->sql_fetchrow($result));
|
while ($row = $db->sql_fetchrow($result));
|
||||||
|
|
||||||
/**
|
|
||||||
* @var \phpbb\messenger\method\messenger_interface $messenger_method
|
|
||||||
* @psalm-suppress UndefinedMethod
|
|
||||||
*/
|
|
||||||
foreach ($messenger_collection_iterator as $messenger_method)
|
|
||||||
{
|
|
||||||
$messenger_method->save_queue();
|
|
||||||
}
|
|
||||||
|
|
||||||
// Add the remind state to the database and increase activation expiration by one day
|
// Add the remind state to the database and increase activation expiration by one day
|
||||||
$sql = 'UPDATE ' . USERS_TABLE . '
|
$sql = 'UPDATE ' . USERS_TABLE . '
|
||||||
SET user_reminded = user_reminded + 1,
|
SET user_reminded = user_reminded + 1,
|
||||||
|
|
|
@ -157,9 +157,6 @@ class ucp_resend
|
||||||
]);
|
]);
|
||||||
|
|
||||||
$messenger_method->send();
|
$messenger_method->send();
|
||||||
|
|
||||||
// Save the queue in the messenger method class (has to be called or these messages could be lost)
|
|
||||||
$messenger_method->save_queue();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Add table
Reference in a new issue