Обработка сообщений по подписке

Подписка обеспечивает фильтрацию сообщений. Фильтрация сообщений осуществляется в соответствии с уникальными идентификаторами отправителей и получателей, определенных в объекте подписки. Сообщения хранятся в подписке до их запроса получателем или до их удаления из подписки.

Типовой цикл обработки сообщений по подписке включает следующие шаги:

1. Отправка сообщений через точки подключения.

   Объекты платформы отправляют сообщения c помощью метода MessageEndpoint::send_message().

2. Маршрутизация и фильтрация сообщений.

   После вызова метода route_messages() шина сообщений MessageBus распределяет сообщения по подпискам в соответствии с определенными в них уникальными идентификаторами отправителей и получателей сообщений.

3. Доставка сообщений до получателей.

   Получатель запрашивает сообщения с помощью методов receive_all_messages() и unload_messages() класса MessageEndpoint.