namespace Friendica\Worker;
-use Friendica\Core\Logger;
+use Friendica\DI;
use Friendica\Protocol\ActivityPub\Queue;
class ProcessQueue
*/
public static function execute(int $id)
{
- Logger::info('Start processing queue entry', ['id' => $id]);
+ DI::logger()->info('Start processing queue entry', ['id' => $id]);
$result = Queue::process($id);
- Logger::info('Successfully processed queue entry', ['result' => $result, 'id' => $id]);
+ DI::logger()->info('Successfully processed queue entry', ['result' => $result, 'id' => $id]);
}
}
namespace Friendica\Worker;
-use Friendica\Core\Logger;
+use Friendica\DI;
use Friendica\Protocol\ActivityPub\Queue;
class ProcessReplyByUri
*/
public static function execute(string $uri)
{
- Logger::info('Start processing queued replies', ['url' => $uri]);
+ DI::logger()->info('Start processing queued replies', ['url' => $uri]);
$count = Queue::processReplyByUri($uri);
- Logger::info('Successfully processed queued replies', ['count' => $count, 'url' => $uri]);
+ DI::logger()->info('Successfully processed queued replies', ['count' => $count, 'url' => $uri]);
}
}
namespace Friendica\Worker;
-use Friendica\Core\Logger;
+use Friendica\DI;
use Friendica\Protocol\ActivityPub\Queue;
class ProcessUnprocessedEntries
*/
public static function execute()
{
- Logger::info('Start processing unprocessed entries');
+ DI::logger()->info('Start processing unprocessed entries');
Queue::processAll();
- Logger::info('Successfully processed unprocessed entries');
+ DI::logger()->info('Successfully processed unprocessed entries');
}
}