SummaryReportObserver implements Serializable { public void observerJobEvents(@Observes final JobEvent jobEvent) { if (jobEvent.getEvent() == JobLifecycleEvent.JOB_FINISHED) { Thread thread = new Thread( new SummaryReportRunner(tankConfig.getControllerBase(), jobEventProducer, jobEvent)); thread.setDaemon(true); thread.setPriority(Thread.MIN_PRIORITY); thread.start(); } }  void observerJobEvents(@Observes final JobEvent jobEvent);  }
@Test public void testObserverJobEvents_1() throws Exception { SummaryReportObserver fixture = new SummaryReportObserver(); JobEvent jobEvent = new JobEvent("", "", JobLifecycleEvent.AGENT_EXCESSIVE_CPU); fixture.observerJobEvents(jobEvent); }
@Test public void testObserverJobEvents_2() throws Exception { SummaryReportObserver fixture = new SummaryReportObserver(); JobEvent jobEvent = new JobEvent("", "", JobLifecycleEvent.AGENT_EXCESSIVE_CPU); fixture.observerJobEvents(jobEvent); }