khusamov-message-broker v0.0.2

Брокер сообщений MessageBroker

Главная идея брокера сообщений в том, что сообщения: 1) сначала попадают в очередь сообщений IMessage[] при помощи метода MessageBroker.publish(), 2) а затем оттуда извлекаются и отправляются в передатчик сообщений MessageEmitter при помощи метода MessageEmitter.emit() 4) и вызываются все слушатели этого сообщения. 5) После вызова MessageEmitter.emit() очередь очищается. 6) Содержимое очереди доступно.

Для чего нужен доступ к очереди сообщений? Например, когда в момент подписки возможно ситуация, что сообщение было уже отправлено и нельзя его уже перехватить. С брокером MessageBroker можно сначала просмотреть очередь. Или воспользоваться специальным методом MessageBroker.awaitMessage() для подписки на сообщения, которые в момент подписки могут быть уже опубликованы.