Consumer Threads now attempt to reconnect on connection errors