add pipeline support
work on pubsub