io.eventuate.testutil

Class EventTracker

java.lang.Object

io.eventuate.testutil.EventTracker

public class EventTracker
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
EventTracker()

Method Summary

Modifier and Type	Method and Description
<T extends Event> void	add(DispatchedEvent<T> ctx)
<T extends Event> DispatchedEvent<T>	assertMessagePublished(java.lang.String entityId, java.lang.Class<T> eventClass)
java.util.concurrent.BlockingQueue<DispatchedEvent<Event>>	getEvents()

Methods inherited from class java.lang.Object

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

Constructor Detail

EventTracker

public EventTracker()

Method Detail

getEvents

public java.util.concurrent.BlockingQueue<DispatchedEvent<Event>> getEvents()

add

public <T extends Event> void add(DispatchedEvent<T> ctx)

assertMessagePublished

public <T extends Event> DispatchedEvent<T> assertMessagePublished(java.lang.String entityId,
                                                                   java.lang.Class<T> eventClass)