implemented in-memory subscription distributor