public BlockingQueue < CollectionDocument > getQueue ( String queueName ) { Preconditions . checkArgument ( registry . containsKey ( queueName ) , "Queue %s does not exist" , queueName ) ; return registry . get ( queueName ) ; }
Retrieves and returns a registered queue by name .