-changed QueueConsumer so return connection stays open