Added a an in-process pubsub implementation