testing the new streaming message consumer