diff --git a/app/init/resources/request.php b/app/init/resources/request.php index 70d691370d..1ee6d79d4a 100644 --- a/app/init/resources/request.php +++ b/app/init/resources/request.php @@ -12,6 +12,7 @@ use Appwrite\Event\Event; use Appwrite\Event\Func; use Appwrite\Event\Mail; use Appwrite\Event\Messaging; +use Appwrite\Event\Notification; use Appwrite\Event\Realtime; use Appwrite\Event\Webhook; use Appwrite\Extend\Exception; @@ -123,6 +124,9 @@ return function (Container $container): void { $container->set('queueForMails', function (Publisher $publisher) { return new Mail($publisher); }, ['publisher']); + $container->set('queueForNotifications', function (Publisher $publisher) { + return new Notification($publisher); + }, ['publisher']); $container->set('queueForBuilds', function (Publisher $publisher) { return new Build($publisher); }, ['publisher']); diff --git a/app/init/worker/message.php b/app/init/worker/message.php index 17796fadcd..c61ed64f06 100644 --- a/app/init/worker/message.php +++ b/app/init/worker/message.php @@ -7,6 +7,7 @@ use Appwrite\Event\Event; use Appwrite\Event\Func; use Appwrite\Event\Mail; use Appwrite\Event\Messaging; +use Appwrite\Event\Notification; use Appwrite\Event\Realtime; use Appwrite\Event\Webhook; use Appwrite\Usage\Context; @@ -342,6 +343,10 @@ return function (Container $container): void { return new Mail($publisher); }, ['publisher']); + $container->set('queueForNotifications', function (Publisher $publisher) { + return new Notification($publisher); + }, ['publisher']); + $container->set('queueForBuilds', function (Publisher $publisher) { return new Build($publisher); }, ['publisher']);