Added  BaseConnection handle redis stream