Package akka.javasdk.testkit

Interface EventingTestKit

public interface EventingTestKit

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	EventingTestKit.IncomingMessages	Allows to simulate publishing messages for the purposes of testing incoming message flow.
static interface	EventingTestKit.Message<P>
static class	EventingTestKit.MessageBuilder
static interface	EventingTestKit.OutgoingMessages	Allows to assert published messages for the purposes of testing outgoing message flow.

Method Summary

Modifier and Type	Method	Description
EventingTestKit.IncomingMessages	getEventSourcedEntityIncomingMessages(String typeId)
EventingTestKit.IncomingMessages	getKeyValueEntityIncomingMessages(String typeId)
EventingTestKit.IncomingMessages	getStreamIncomingMessages(String service, String streamId)
EventingTestKit.IncomingMessages	getTopicIncomingMessages(String topic)
EventingTestKit.OutgoingMessages	getTopicOutgoingMessages(String topic)
EventingTestKit.IncomingMessages	getWorkflowIncomingMessages(String typeId)
static EventingTestKit	start(akka.actor.typed.ActorSystem<?> system, String host, int port, akka.javasdk.impl.serialization.JsonSerializer serializer)	INTERNAL API

Method Details

start

@InternalApi
static EventingTestKit start(akka.actor.typed.ActorSystem<?> system,
 String host,
 int port,
 akka.javasdk.impl.serialization.JsonSerializer serializer)

INTERNAL API

getTopicOutgoingMessages

EventingTestKit.OutgoingMessages getTopicOutgoingMessages(String topic)

getTopicIncomingMessages

EventingTestKit.IncomingMessages getTopicIncomingMessages(String topic)

getKeyValueEntityIncomingMessages

EventingTestKit.IncomingMessages getKeyValueEntityIncomingMessages(String typeId)

getEventSourcedEntityIncomingMessages

EventingTestKit.IncomingMessages getEventSourcedEntityIncomingMessages(String typeId)

getWorkflowIncomingMessages

EventingTestKit.IncomingMessages getWorkflowIncomingMessages(String typeId)

getStreamIncomingMessages

EventingTestKit.IncomingMessages getStreamIncomingMessages(String service,
 String streamId)