io.eventuate.testutil

Class AbstractTestEventHandler

java.lang.Object

io.eventuate.testutil.AbstractTestEventHandler

public abstract class AbstractTestEventHandler
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected EventTracker	eventTracker
protected org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
AbstractTestEventHandler()

Method Summary

Modifier and Type	Method and Description
<T extends Event> void	add(DispatchedEvent<T> ctx)
<T extends Event> void	add(EventHandlerContext<T> ctx)
<T extends Event> ReceivedEvent	assertMessagePublished(java.lang.String entityId, java.lang.Class<T> eventClass)
ReceivedEvent	assertMessagePublished(java.lang.String message, java.util.function.Predicate<ReceivedEvent> predicate)
ReceivedEvent	eventuallyContains(java.lang.String message, io.eventuate.common.id.Int128 eventId)
ReceivedEvent	eventuallyContains(java.lang.String message, java.util.function.Predicate<ReceivedEvent> predicate)

Methods inherited from class java.lang.Object

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

Field Detail

eventTracker

protected EventTracker eventTracker

logger

protected org.slf4j.Logger logger

Constructor Detail

AbstractTestEventHandler

public AbstractTestEventHandler()

Method Detail

add

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

add

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

assertMessagePublished

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

assertMessagePublished

public ReceivedEvent assertMessagePublished(java.lang.String message,
                                            java.util.function.Predicate<ReceivedEvent> predicate)

eventuallyContains

public ReceivedEvent eventuallyContains(java.lang.String message,
                                        java.util.function.Predicate<ReceivedEvent> predicate)

eventuallyContains

public ReceivedEvent eventuallyContains(java.lang.String message,
                                        io.eventuate.common.id.Int128 eventId)