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

Class AggregatingListener

java.lang.Object

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

public class AggregatingListener
extends java.lang.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 java.util.ArrayList<IEvent>	eventStream
private org.junit.runner.Description	lastSuite
private ForkedJvmInfo	slave
private AggregatedSuiteStartedEvent	startEvent
private java.util.List<FailureMirror>	suiteFailures
private com.google.common.eventbus.EventBus	target
private java.util.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 java.lang.Object

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

Field Detail

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 java.util.List<FailureMirror> suiteFailures

tests

private java.util.ArrayDeque<AggregatedTestResultEvent> tests

eventStream

private java.util.ArrayList<IEvent> eventStream

testStartStreamMarker

private int testStartStreamMarker

Constructor Detail

AggregatingListener

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

Parameters:

target - Which event bus to repost aggregated events to?

Method Detail

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)