XMLWorker implements XMLParserListener { public void startElement(final String tag, final Map<String, String> attr, final String ns) { Tag t = createTag(tag, attr, ns); WorkerContext ctx = getLocalWC(); if (null != ctx.getCurrentTag()) { ctx.getCurrentTag().addChild(t); } ctx.setCurrentTag(t); Pipeline<?> wp = rootpPipe; ProcessObject po = new ProcessObject(); try { while (null != (wp = wp.open(ctx, t, po))) ; } catch (PipelineException e) { throw new RuntimeWorkerException(e); } } XMLWorker(final Pipeline<?> pipeline, final boolean parseHtml); void init(); void startElement(final String tag, final Map<String, String> attr, final String ns); void endElement(final String tag, final String ns); void text(String text); void unknownText(final String text); void comment(final String comment); void close();  }
@Test public void verifyPipelineOpenCalled() { worker.startElement("test", new HashMap<String, String>() , "ns"); Assert.assertTrue(called); }