Package kalix.javasdk.testkit

Class KalixTestKit.MockedEventing

Object

kalix.javasdk.testkit.KalixTestKit.MockedEventing

Enclosing class:

KalixTestKit

public static class KalixTestKit.MockedEventing
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static KalixTestKit.MockedEventing	EMPTY
static final String	EVENT_SOURCED_ENTITY
static final String	STREAM
static final String	TOPIC
static final String	VALUE_ENTITY

Method Summary

Modifier and Type	Method	Description
boolean	hasConfig()
boolean	hasIncomingConfig()
boolean	hasOutgoingConfig()
String	toIncomingFlowConfig()
String	toOutgoingFlowConfig()
String	toString()
KalixTestKit.MockedEventing	withEventSourcedIncomingMessages(String typeId)
KalixTestKit.MockedEventing	withStreamIncomingMessages(String service, String streamId)
KalixTestKit.MockedEventing	withTopicIncomingMessages(String topic)
KalixTestKit.MockedEventing	withTopicOutgoingMessages(String topic)
KalixTestKit.MockedEventing	withValueEntityIncomingMessages(String typeId)

Methods inherited from class java.lang.Object

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

Field Details

VALUE_ENTITY

public static final String VALUE_ENTITY

See Also:

• Constant Field Values

EVENT_SOURCED_ENTITY

public static final String EVENT_SOURCED_ENTITY

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 KalixTestKit.MockedEventing EMPTY

Method Details

withValueEntityIncomingMessages

public KalixTestKit.MockedEventing withValueEntityIncomingMessages(String typeId)

withEventSourcedIncomingMessages

public KalixTestKit.MockedEventing withEventSourcedIncomingMessages(String typeId)

withStreamIncomingMessages

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

withTopicIncomingMessages

public KalixTestKit.MockedEventing withTopicIncomingMessages(String topic)

withTopicOutgoingMessages

public KalixTestKit.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()