php?
В большинстве случаев (не только в php) такие либы идут сразу со своим подобием event loop'a для подписок.
типа (new Subscriber())->onMessage($handler)->run().
Либа сразу становится комбайном, надо тащить pcntl, писать обработку ошибок, делать апи позволяющее стопнуть луп извне и прочее.
Не могу понять, как сделать чтобы просто и удобно
в каком контексте ? внутри одного пхп процесса или как?
это уже не в контексте пхп-процесса, там прилететь может что угодно…
https://github.com/php-service-bus/transport/blob/v4.2/src/Common/Transport.php
Всмысле?
Внутри пхп-процесса мы можем четко контролировать какие события летают, делать что-то вроде subscribe(function (OrderCreated $event) {…}. ) и всё
Похоже весь мой головняк связан именно со сложностью кролика. Все эти TopicBInd и routingKey сложно
ну там нет особо ничего сложного, так-то
https://github.com/php-service-bus/service-bus/blob/v4.1/src/EntryPoint/EntryPoint.php а так выглядит уже интерфейс самого консамера. Тоже ровно 2 метода, больше ничё не надо. конфигурация транспорта отдельно, консам - отдельно
Queue это у одного топика несколько каналов, чтобы разные косьюмеры получали копии?
в контексте текущего транспорта
Обсуждают сегодня