Class AggregatingListener

java.lang.Object

com.carrotsearch.ant.tasks.junit4.events.aggregated.AggregatingListener

public class AggregatingListener
extends Object

Aggregates atomic events from JUnitCore to higher-level events that contain a full summary of a given test's execution. Simplifies reporting logic.

Field Summary

Fields

Modifier and Type	Field	Description
private ArrayList<IEvent>	eventStream
private org.junit.runner.Description	lastSuite
private ForkedJvmInfo	slave
private AggregatedSuiteStartedEvent	startEvent
private List<FailureMirror>	suiteFailures
private com.google.common.eventbus.EventBus	target
private ArrayDeque<AggregatedTestResultEvent>	tests
private int	testStartStreamMarker

Constructor Summary

Constructors

Constructor	Description
AggregatingListener(com.google.common.eventbus.EventBus target, ForkedJvmInfo slave)

Method Summary

Modifier and Type	Method	Description
void	appendToEventStream(IEvent e)
void	receiveSuiteEnd(SuiteCompletedEvent e)
void	receiveSuiteFailure(SuiteFailureEvent e)
void	receiveSuiteStart(SuiteStartedEvent e)
void	receiveTestAssumptionIgnored(TestIgnoredAssumptionEvent e)
void	receiveTestEnd(TestFinishedEvent e)
void	receiveTestFailure(TestFailureEvent e)
void	receiveTestIgnored(TestIgnoredEvent e)
void	receiveTestStart(TestStartedEvent e)
void	slowHeartBeat(LowLevelHeartBeatEvent e)	Detect slow heartbeat (long time without any events) from the forked JVM.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

target

private com.google.common.eventbus.EventBus target

slave

private ForkedJvmInfo slave

startEvent

private AggregatedSuiteStartedEvent startEvent

lastSuite

private org.junit.runner.Description lastSuite

suiteFailures

private List<FailureMirror> suiteFailures

tests

private ArrayDeque<AggregatedTestResultEvent> tests

eventStream

private ArrayList<IEvent> eventStream

testStartStreamMarker

private int testStartStreamMarker

Constructor Details

AggregatingListener

public AggregatingListener(com.google.common.eventbus.EventBus target,
 ForkedJvmInfo slave)

Parameters:

target - Which event bus to repost aggregated events to?

Method Details

appendToEventStream

public void appendToEventStream(IEvent e)

slowHeartBeat

public void slowHeartBeat(LowLevelHeartBeatEvent e)

Detect slow heartbeat (long time without any events) from the forked JVM.

receiveSuiteStart

public void receiveSuiteStart(SuiteStartedEvent e)

receiveTestStart

public void receiveTestStart(TestStartedEvent e)

receiveTestIgnored

public void receiveTestIgnored(TestIgnoredEvent e)

receiveTestAssumptionIgnored

public void receiveTestAssumptionIgnored(TestIgnoredAssumptionEvent e)

receiveTestFailure

public void receiveTestFailure(TestFailureEvent e)

receiveTestEnd

public void receiveTestEnd(TestFinishedEvent e)

receiveSuiteEnd

public void receiveSuiteEnd(SuiteCompletedEvent e)

receiveSuiteFailure

public void receiveSuiteFailure(SuiteFailureEvent e)