Add pub/sub

• Consider using watermill for pub/sub. If possible for testing use go channels https://watermill.io/pubsubs/gochannel/