Package akka.javasdk.testkit

Class TestKit.MockedEventing

Object

akka.javasdk.testkit.TestKit.MockedEventing

Enclosing class:

TestKit

public static class TestKit.MockedEventing
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final TestKit.MockedEventing	EMPTY
static final String	EVENT_SOURCED_ENTITY
static final String	KEY_VALUE_ENTITY
static final String	STREAM
static final String	TOPIC
static final String	WORKFLOW

Method Summary

Modifier and Type	Method	Description
boolean	hasConfig()
boolean	hasIncomingConfig()
boolean	hasOutgoingConfig()
String	toIncomingFlowConfig()
String	toOutgoingFlowConfig()
String	toString()
TestKit.MockedEventing	withEventSourcedIncomingMessages(String componentId)
TestKit.MockedEventing	withKeyValueEntityIncomingMessages(String componentId)
TestKit.MockedEventing	withStreamIncomingMessages(String service, String streamId)
TestKit.MockedEventing	withTopicIncomingMessages(String topic)
TestKit.MockedEventing	withTopicOutgoingMessages(String topic)
TestKit.MockedEventing	withWorkflowIncomingMessages(String componentId)

Methods inherited from class java.lang.Object

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

Field Details

KEY_VALUE_ENTITY

public static final String KEY_VALUE_ENTITY

See Also:

• Constant Field Values

EVENT_SOURCED_ENTITY

public static final String EVENT_SOURCED_ENTITY

See Also:

• Constant Field Values

WORKFLOW

public static final String WORKFLOW

See Also:

• Constant Field Values

STREAM

public static final String STREAM

See Also:

• Constant Field Values

TOPIC

public static final String TOPIC

See Also:

• Constant Field Values

EMPTY

public static final TestKit.MockedEventing EMPTY

Method Details

withKeyValueEntityIncomingMessages

public TestKit.MockedEventing withKeyValueEntityIncomingMessages(String componentId)

withEventSourcedIncomingMessages

public TestKit.MockedEventing withEventSourcedIncomingMessages(String componentId)

withWorkflowIncomingMessages

public TestKit.MockedEventing withWorkflowIncomingMessages(String componentId)

withStreamIncomingMessages

public TestKit.MockedEventing withStreamIncomingMessages(String service,
 String streamId)

withTopicIncomingMessages

public TestKit.MockedEventing withTopicIncomingMessages(String topic)

withTopicOutgoingMessages

public TestKit.MockedEventing withTopicOutgoingMessages(String topic)

toString

public String toString()

Overrides:

toString in class Object

hasIncomingConfig

public boolean hasIncomingConfig()

hasConfig

public boolean hasConfig()

hasOutgoingConfig

public boolean hasOutgoingConfig()

toIncomingFlowConfig

public String toIncomingFlowConfig()

toOutgoingFlowConfig

public String toOutgoingFlowConfig()