Added retry to rabbitmq consumer and producer when server disconnects