Summary
Functions
Returns a specification to start this module under a supervisor.
Отдать событие консьюмеру клиента name. wire — в каком виде транспорт
отдал payload: :bytes (как лежит в шине) или :json (значение JSON-ответа).
Консьюмера нет (клиент только публикует или Worker перезапускается) —
событие не подтверждено, шина доставит его снова.
Вернётся, когда консьюмер разберёт всё, что ему отдали до этого вызова:
вызов встаёт в очередь Worker'а за событиями. Противодавление для тех, кто
забирает события сам (HTTP long-poll): следующая пачка — после этой.
:ok или :gone, если Worker'а нет или он не дождался.
Callback implementation for GenServer.init/1.
Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Отдать событие консьюмеру клиента name. wire — в каком виде транспорт
отдал payload: :bytes (как лежит в шине) или :json (значение JSON-ответа).
Консьюмера нет (клиент только публикует или Worker перезапускается) —
событие не подтверждено, шина доставит его снова.
Вернётся, когда консьюмер разберёт всё, что ему отдали до этого вызова:
вызов встаёт в очередь Worker'а за событиями. Противодавление для тех, кто
забирает события сам (HTTP long-poll): следующая пачка — после этой.
:ok или :gone, если Worker'а нет или он не дождался.
Callback implementation for GenServer.init/1.