Modified test consumer to use durable queue