khusamov-message-broker

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

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

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