Splitting messages and re-aggregating them using different criteria