Add retry logic and bump to 0.4.0
Enable concurrency in consumers