Class AggregatingListener
- java.lang.Object
-
- com.carrotsearch.ant.tasks.junit4.events.aggregated.AggregatingListener
-
public class AggregatingListener extends java.lang.Object
Aggregates atomic events fromJUnitCore
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
All Methods Instance Methods Concrete Methods 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.
-
-
-
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)
-
-