create an example of a policy which collects events from two aggregates and generate a command for a third aggregate