Started to factor out subscription handling to SubscriptionListener. Not
yet finished, in particular subscription replay is still open.