Add implementation for Publish/Subscribe