[MAILBOX-368] Implement a work queue for listeners

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.3.0
• Assignee: Unassigned
• Reporter: Trần Tiến Đức
• Created: 25/Dec/18 08:22
• Updated: 11/Jan/19 09:58
• Resolved: 11/Jan/19 09:58

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