Added AmqpDuplexQueue which uses separate connections for pushing and consuming