Migrate queue to publish and subscribe to generic BaseEvent

Refactor publish and subscribe to generic BaseEvent, from the specified MessageEvent. This enforce decoupling and let the publisher and subscriber handle different event types.