added Pipeline pubsub implementation