### Question:
OwlOntologyProducer implements Callable<Long> { public void queueObjects(OWLOntologyManager manager, OntologySetup ontologyConfig) throws InterruptedException { String origThreadName = Thread.currentThread().getName(); Thread.currentThread().setName("queueing axioms - " + ontologyConfig); logger.info("Queueing axioms for: " + ontologyConfig); long objectCount = 0; for (OWLOntology ontology : manager.getOntologies()) { String ontologyIri = OwlApiUtils.getIri(ontology); queue.put(new OWLCompositeObject(ontologyIri, ontology)); for (OWLObject object : ontology.getNestedClassExpressions()) { queue.put(new OWLCompositeObject(ontologyIri, object)); objectCount++; } for (OWLObject object : ontology.getClassesInSignature(false)) { queue.put(new OWLCompositeObject(ontologyIri, object)); objectCount++; } for (OWLObject object : ontology.getAxioms()) { queue.put(new OWLCompositeObject(ontologyIri, object)); objectCount++; } for (OWLAnnotation annotation : ontology.getAnnotations()) { OWLAnnotationSubject ontologySubject = IRI.create(ontologyIri); OWLAnnotationAssertionAxiom object = new OWLAnnotationAssertionAxiomImpl(ontologySubject, annotation.getProperty(), annotation.getValue(), new ArrayList<OWLAnnotation>()); queue.put(new OWLCompositeObject(ontologyIri, object)); objectCount++; } } Thread.currentThread().setName(origThreadName); logger.info("Finished queueing " + objectCount + " axioms for: " + ontologyConfig); } @Inject  OwlOntologyProducer(BlockingQueue<OWLCompositeObject> queue,
      BlockingQueue<OntologySetup> ontologyQueue,
      @IndicatesNumberOfShutdownProducers AtomicInteger numProducersShutdown, Graph graph); void reason(OWLOntologyManager manager, OWLOntology ont, OntologySetup config); void queueObjects(OWLOntologyManager manager, OntologySetup ontologyConfig); @Override Long call();  }### Answer:
@Test public void objects_areQueued() throws InterruptedException { OntologySetup ontologyConfig = new OntologySetup(); ontologyConfig.setUrl("http: producer.queueObjects(manager, ontologyConfig); assertThat(queue.size(), is(greaterThan(0))); }