diff options
| author | Mario <mario@mariovavti.com> | 2020-11-13 13:49:39 +0000 |
|---|---|---|
| committer | Mario <mario@mariovavti.com> | 2020-11-13 13:49:39 +0000 |
| commit | 685c569eaf094fd7f354bd3fa8026ecefadfa590 (patch) | |
| tree | cbb96917c668859dcb82770da987d92471dde125 /Zotlabs/Daemon/Notifier.php | |
| parent | b6e34695197191275d6d9f4f63f7f976bcf89a2d (diff) | |
| download | volse-hubzilla-685c569eaf094fd7f354bd3fa8026ecefadfa590.tar.gz volse-hubzilla-685c569eaf094fd7f354bd3fa8026ecefadfa590.tar.bz2 volse-hubzilla-685c569eaf094fd7f354bd3fa8026ecefadfa590.zip | |
minor queue adjustments
Diffstat (limited to 'Zotlabs/Daemon/Notifier.php')
| -rw-r--r-- | Zotlabs/Daemon/Notifier.php | 23 |
1 files changed, 13 insertions, 10 deletions
diff --git a/Zotlabs/Daemon/Notifier.php b/Zotlabs/Daemon/Notifier.php index 8ea75af61..f24eab773 100644 --- a/Zotlabs/Daemon/Notifier.php +++ b/Zotlabs/Daemon/Notifier.php @@ -4,6 +4,7 @@ namespace Zotlabs\Daemon; use Zotlabs\Lib\Libzot; use Zotlabs\Lib\Activity; +use Zotlabs\Lib\Queue; require_once('include/queue_fn.php'); require_once('include/html2plain.php'); @@ -734,15 +735,17 @@ class Notifier { } if($packet) { - queue_insert(array( - 'hash' => $hash, - 'account_id' => $channel['channel_account_id'], - 'channel_id' => $channel['channel_id'], - 'posturl' => $hub['hubloc_callback'], - 'driver' => $hub['hubloc_network'], - 'notify' => $packet, - 'msg' => (($pmsg) ? json_encode($pmsg) : '') - )); + Queue::insert( + [ + 'hash' => $hash, + 'account_id' => $channel['channel_account_id'], + 'channel_id' => $channel['channel_id'], + 'posturl' => $hub['hubloc_callback'], + 'driver' => $hub['hubloc_network'], + 'notify' => $packet, + 'msg' => (($pmsg) ? json_encode($pmsg) : '') + ] + ); } else { $env = (($hub_env && $hub_env[$hub['hubloc_host'] . $hub['hubloc_sitekey']]) ? $hub_env[$hub['hubloc_host'] . $hub['hubloc_sitekey']] : ''); @@ -803,7 +806,7 @@ class Notifier { } } - queue_insert( + Queue::insert( [ 'hash' => $hash, 'account_id' => $target_item['aid'], |