Package akka.javasdk.testkit
Interface EventingTestKit
public interface EventingTestKit
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic interfaceAllows to simulate publishing messages for the purposes of testing incoming message flow.static interfacestatic classstatic interfaceAllows to assert published messages for the purposes of testing outgoing message flow. -
Method Summary
Modifier and TypeMethodDescriptiongetStreamIncomingMessages(String service, String streamId) getStreamOutgoingMessages(String service, String streamId) getTopicIncomingMessages(String topic) getTopicOutgoingMessages(String topic) getWorkflowIncomingMessages(String typeId)
-
Method Details
-
getTopicOutgoingMessages
-
getTopicIncomingMessages
-
getKeyValueEntityIncomingMessages
-
getEventSourcedEntityIncomingMessages
-
getWorkflowIncomingMessages
-
getStreamIncomingMessages
-
getStreamOutgoingMessages
-