replaced Collector with GroupMessage