Add utility method for creating partitions
Fix concurrency issues
Add parametrizable message reception test - extract abstract class - to be used with different other configuraitons.