Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
Following work done in MAILBOX-367 we will handle asynchronous execution for listener, as defined in API MAILBOX-364
interface EventBus {
... Registration register(Listener listener, Group group); ...
}
- Upon new group registration, RabbitMQEventBus attempts to create a queue per listener group, bounded to the exhange introduced in
MAILBOX-367. - RabbitMQEventBus also registers a consumer executing the given listener group - bound to the listener group queue
For test:
- With a single RabbitMQDelegatingListener, ensure that global listeners are correctly executed
- With 2 RabbitMQDelegatingListener, ensure that all global listeners are executed at least once accross the cluster