Common stream consumer class instead of duplicates throught the project