private BlockingQueueConsumer createConsumer(RabbitAccessor accessor) {
BlockingQueueConsumer consumer = new BlockingQueueConsumer(
accessor.getConnectionFactory(), new DefaultMessagePropertiesConverter(),
new ActiveObjectCounter<BlockingQueueConsumer>(), AcknowledgeMode.AUTO, true, 1, queue.getName());
consumer.start();
// wait for consumeOk...
int n = 0;
while (n++ < 100) {
if (consumer.getConsumerTag() == null) {
try {