TODOs for backpressure in aggregate subscription.
Support close aggreate subscriptions.
PubSub message ordering.
Add ack for subscribe/unsubscribe.
Add bridge from AggregateEvent to PubSub.
EventPublisher is now more generic, only manages subscriptions and now called AggregateSubscriptionManager.