Package kalix.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.
static interface	EventingTestKit.Topic	Testkit utility to mock broker's topic.

Method Summary

Modifier and Type	Method	Description
EventingTestKit.IncomingMessages	getEventSourcedEntityIncomingMessages(String typeId)
EventingTestKit.IncomingMessages	getStreamIncomingMessages(String service, String streamId)
EventingTestKit.Topic	getTopic(String topic)	Deprecated.
EventingTestKit.IncomingMessages	getTopicIncomingMessages(String topic)
EventingTestKit.OutgoingMessages	getTopicOutgoingMessages(String topic)
EventingTestKit.IncomingMessages	getValueEntityIncomingMessages(String typeId)
static EventingTestKit	start(akka.actor.ActorSystem system, String host, int port, kalix.javasdk.impl.MessageCodec codec)	INTERNAL API

Method Details

start

@InternalApi
static EventingTestKit start(akka.actor.ActorSystem system,
 String host,
 int port,
 kalix.javasdk.impl.MessageCodec codec)

INTERNAL API

getTopic

@Deprecated
EventingTestKit.Topic getTopic(String topic)

Deprecated.

Use getTopicOutgoingMessages or getTopicIncomingMessages instead.

getTopicOutgoingMessages

EventingTestKit.OutgoingMessages getTopicOutgoingMessages(String topic)

getTopicIncomingMessages

EventingTestKit.IncomingMessages getTopicIncomingMessages(String topic)

getValueEntityIncomingMessages

EventingTestKit.IncomingMessages getValueEntityIncomingMessages(String typeId)

getEventSourcedEntityIncomingMessages

EventingTestKit.IncomingMessages getEventSourcedEntityIncomingMessages(String typeId)

getStreamIncomingMessages

EventingTestKit.IncomingMessages getStreamIncomingMessages(String service,
 String streamId)