Класс MessageBus
Класс MessageBus реализует интерфейс для доступа к шине сообщений. Шина сообщений обеспечивает прием, распределение и доставку сообщений между подключенными к ней объектами.
Класс MessageBus предоставляет методы, с помощью которых вы можете выполнять следующие действия:
- создавать шины сообщений;
- создавать точки подключения к шине сообщений;
- принимать, распределять доставлять сообщения между объектами, подключенными к шине сообщений;
- получать используемые точки подключения.
Шина сообщений предоставляет множество точек подключения MessageEndpoint, с помощью которых объекты платформы и объекты внешней среды могут подписаться на сообщения или отправить их. Вы можете создать точки подключения к шине сообщений и затем подписать созданные точки подключения на сообщения определенного типа с помощью метода подписки MessageEndpoint::subscribe(). Если вы удалите точку подключения, то передача сообщений с помощью этой точки подключения прекратится.
Использование шины сообщений позволяет реализовать принцип "издатель-подписчик". Издатель отправляет сообщения через посредника, в качестве которого выступает шина сообщений. Объект подписки Subscription фильтрует сообщения и отправляет их подписчикам. Подобный подход позволяет избежать создания большого количества IPC-каналов, поскольку издатель и подписчики не связаны напрямую.
Подробнее о методах шины сообщений MessageBus см. в API-документации Kaspersky Neuromorphic Platform.
