Index

A B C D E F G H I K M O P S T V W
All Classes and Interfaces|All Packages|Constant Field Values

A

aclEnabled - Variable in class akka.javasdk.testkit.TestKit.Settings

Whether ACL checking is enabled.

additionalConfig - Variable in class akka.javasdk.testkit.TestKit.Settings

afterAll() - Method in class akka.javasdk.testkit.TestKitSupport

afterAll(ExtensionContext) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

JUnit5 support - extension based

akka.javasdk.testkit - package akka.javasdk.testkit

akka.javasdk.testkit.impl - package akka.javasdk.testkit.impl

akka.javasdk.testkit.junit.jupiter - package akka.javasdk.testkit.junit.jupiter

AsyncCallsSupport - Class in akka.javasdk.testkit

AsyncCallsSupport() - Constructor for class akka.javasdk.testkit.AsyncCallsSupport

availableLocalPort() - Static method in class akka.javasdk.testkit.TestKit

Get an available local port for testing.

await(CompletionStage<O>) - Method in class akka.javasdk.testkit.AsyncCallsSupport

await(CompletionStage<O>, Duration) - Method in class akka.javasdk.testkit.AsyncCallsSupport

B

beforeAll() - Method in class akka.javasdk.testkit.TestKitSupport

beforeAll(ExtensionContext) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

JUnit5 support - extension based

C

call(Function<A, TimedAction.Effect>) - Method in class akka.javasdk.testkit.TimedActionTestkit

The call method can be used to simulate a unary call to the Action.

call(Function<A, TimedAction.Effect>, Metadata) - Method in class akka.javasdk.testkit.TimedActionTestkit

The call method can be used to simulate a unary call to the Action.

call(Function<E, KeyValueEntity.Effect<R>>) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit

The call method can be used to simulate a call to the KeyValueEntity.

call(Function<E, KeyValueEntity.Effect<R>>, Metadata) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit

The call method can be used to simulate a call to the KeyValueEntity.

call(Function<ES, EventSourcedEntity.Effect<R>>) - Method in class akka.javasdk.testkit.EventSourcedTestKit

The call method can be used to simulate a call to the EventSourcedEntity.

call(Function<ES, EventSourcedEntity.Effect<R>>, Metadata) - Method in class akka.javasdk.testkit.EventSourcedTestKit

The call method can be used to simulate a call to the EventSourcedEntity.

clear() - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Clear the destination so any existing messages are not considered on subsequent expect call.

componentClient - Variable in class akka.javasdk.testkit.TestKitSupport

create() - Static method in interface akka.javasdk.testkit.MockRegistry

Returns an empty instance of MockRegistry that can be chained with `withMock`

D

DEFAULT - Static variable in class akka.javasdk.testkit.TestKit.Settings

Default settings for testkit.

DeferredCallDetails<I,O> - Interface in akka.javasdk.testkit

dependencyProvider - Variable in class akka.javasdk.testkit.TestKit.Settings

didEmitEvents() - Method in interface akka.javasdk.testkit.EventSourcedResult

E

EMPTY - Static variable in interface akka.javasdk.testkit.MockRegistry

EMPTY - Static variable in class akka.javasdk.testkit.TestKit.MockedEventing

EVENT_SOURCED_ENTITY - Static variable in class akka.javasdk.testkit.TestKit.MockedEventing

eventingSupport - Variable in class akka.javasdk.testkit.TestKit.Settings

EventingTestKit - Interface in akka.javasdk.testkit

EventingTestKit.IncomingMessages - Interface in akka.javasdk.testkit

Allows to simulate publishing messages for the purposes of testing incoming message flow.

EventingTestKit.Message<P> - Interface in akka.javasdk.testkit

EventingTestKit.MessageBuilder - Class in akka.javasdk.testkit

EventingTestKit.OutgoingMessages - Interface in akka.javasdk.testkit

Allows to assert published messages for the purposes of testing outgoing message flow.

EventSourcedEntityEffectsRunner<S,E> - Class in akka.javasdk.testkit.impl

Extended by generated code, not meant for user extension

EventSourcedEntityEffectsRunner(EventSourcedEntity<S, E>) - Constructor for class akka.javasdk.testkit.impl.EventSourcedEntityEffectsRunner

EventSourcedResult<R> - Interface in akka.javasdk.testkit

Represents the result of an EventSourcedEntity handling a command when run in through the testkit.

EventSourcedTestKit<S,E,ES> - Class in akka.javasdk.testkit

EventSourced Testkit for use in unit tests for EventSourced entities.

expectN() - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits for a default amount of time before returning all unread messages.

expectN(int) - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits for a given amount of unread messages to be received before returning.

expectN(int, Duration) - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits for a given amount of unread messages to be received before returning up to a given timeout.

expectNone() - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits for predefined amount of time (see OutgoingMessagesImpl.DefaultTimeout() for default value).

expectNone(Duration) - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits for given amount of time.

expectOne() - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits for predefined amount of time (see OutgoingMessagesImpl.DefaultTimeout() for default value) and returns the next unread message.

expectOne(Duration) - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits for a specific amount and returns the next unread message.

expectOneRaw() - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits and returns the next unread message.

expectOneRaw(Duration) - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits and returns the next unread message.

expectOneTyped(Class<T>) - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits and returns the next unread message and automatically parses and casts it to the specified given type.

expectOneTyped(Class<T>, Duration) - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages

Waits and returns the next unread message and automatically parses and casts it to the specified given type.

expectType(Class<T>) - Method in interface akka.javasdk.testkit.EventingTestKit.Message

Expects message payload to conform to type passed in and returns the typed object if so.

F

failed(CompletionStage<O>) - Method in class akka.javasdk.testkit.AsyncCallsSupport

If completed with an exception, returns the exception.

G

getActorSystem() - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

Get an ActorSystem for creating Akka HTTP clients.

getActorSystem() - Method in class akka.javasdk.testkit.TestKit

Get an ActorSystem for creating Akka HTTP clients.

getAllEvents() - Method in interface akka.javasdk.testkit.EventSourcedResult

getAllEvents() - Method in class akka.javasdk.testkit.impl.EventSourcedEntityEffectsRunner

getApplicationConfig() - Method in class akka.javasdk.testkit.TestKit

getComponentClient() - Method in class akka.javasdk.testkit.TestKit

Get an ComponentClient for interacting "internally" with the components of a service.

getDependency(Class<T>) - Method in class akka.javasdk.testkit.TestKitSupport

getDependencyProvider() - Method in class akka.javasdk.testkit.TestKit

getError() - Method in interface akka.javasdk.testkit.EventSourcedResult

The error description.

getError() - Method in interface akka.javasdk.testkit.KeyValueEntityResult

The error description.

getError() - Method in interface akka.javasdk.testkit.TimedActionResult

getErrorStatusCode() - Method in interface akka.javasdk.testkit.EventSourcedResult

getEventSourcedEntityIncomingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit

getEventSourcedEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

Get incoming messages for EventSourcedEntity.

getEventSourcedEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit

Get incoming messages for EventSourcedEntity.

getHost() - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

Get the host name/IP address where the service is available.

getHost() - Method in class akka.javasdk.testkit.TestKit

Get the host name/IP address where the service is available.

getHttpClientProvider() - Method in class akka.javasdk.testkit.TestKit

Get a HttpClientProvider for looking up HTTP clients to interact with other services than the current.

getKeyValueEntityIncomingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit

getKeyValueEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit

Get incoming messages for KeyValueEntity.

getMaterializer() - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

An Akka Stream materializer to use for running streams.

getMaterializer() - Method in class akka.javasdk.testkit.TestKit

An Akka Stream materializer to use for running streams.

getMessage() - Method in interface akka.javasdk.testkit.DeferredCallDetails

getMessageBuilder() - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

Returns EventingTestKit.MessageBuilder utility to create EventingTestKit.Messages for the eventing testkit.

getMessageBuilder() - Method in class akka.javasdk.testkit.TestKit

Returns EventingTestKit.MessageBuilder utility to create EventingTestKit.Messages for the eventing testkit.

getMessageCodec() - Method in class akka.javasdk.testkit.TestKit

INTERNAL API

getMetadata() - Method in interface akka.javasdk.testkit.DeferredCallDetails

getMetadata() - Method in interface akka.javasdk.testkit.EventingTestKit.Message

getMethodName() - Method in interface akka.javasdk.testkit.DeferredCallDetails

getNextEventOfType(Class<E>) - Method in interface akka.javasdk.testkit.EventSourcedResult

Look at the next event and verify that it is of type E or fail if not or if there is no next event.

getPayload() - Method in interface akka.javasdk.testkit.EventingTestKit.Message

getPort() - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

Get the local port where the Kalix service is available.

getPort() - Method in class akka.javasdk.testkit.TestKit

Get the local port where the service is available.

getReply() - Method in interface akka.javasdk.testkit.EventSourcedResult

The reply object from the handler if there was one.

getReply() - Method in interface akka.javasdk.testkit.KeyValueEntityResult

getSelfHttpClient() - Method in class akka.javasdk.testkit.TestKit

Get a HttpClient for interacting with the service itself, the client will not be authenticated and will appear to the service as a request with the internet principal.

getServiceName() - Method in interface akka.javasdk.testkit.DeferredCallDetails

getState() - Method in class akka.javasdk.testkit.impl.EventSourcedEntityEffectsRunner

getState() - Method in class akka.javasdk.testkit.KeyValueEntityTestKit

getStreamIncomingMessages(String, String) - Method in interface akka.javasdk.testkit.EventingTestKit

getStreamIncomingMessages(String, String) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

Get incoming messages for Stream (eventing.in.direct in case of protobuf SDKs).

getStreamIncomingMessages(String, String) - Method in class akka.javasdk.testkit.TestKit

Get incoming messages for Stream (eventing.in.direct in case of protobuf SDKs).

getTimerScheduler() - Method in class akka.javasdk.testkit.TestKit

Get a TimerScheduler for scheduling TimedAction.

getTopicIncomingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit

getTopicIncomingMessages(String) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

Get incoming messages for Topic.

getTopicIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit

Get incoming messages for Topic.

getTopicOutgoingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit

getTopicOutgoingMessages(String) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

Get mocked topic destination.

getTopicOutgoingMessages(String) - Method in class akka.javasdk.testkit.TestKit

Get mocked topic destination.

getUpdatedState() - Method in interface akka.javasdk.testkit.EventSourcedResult

getUpdatedState() - Method in interface akka.javasdk.testkit.KeyValueEntityResult

getValueEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension

Get incoming messages for ValueEntity.

GOOGLE_PUBSUB - Enum constant in enum class akka.javasdk.testkit.TestKit.Settings.EventingSupport

Used if you want to use an external Google PubSub (or its Emulator) on your tests.

H

handleEvent(S, E) - Method in class akka.javasdk.testkit.EventSourcedTestKit

handleEvent(S, E) - Method in class akka.javasdk.testkit.impl.EventSourcedEntityEffectsRunner

hasConfig() - Method in class akka.javasdk.testkit.TestKit.MockedEventing

hasIncomingConfig() - Method in class akka.javasdk.testkit.TestKit.MockedEventing

hasOutgoingConfig() - Method in class akka.javasdk.testkit.TestKit.MockedEventing

httpClient - Variable in class akka.javasdk.testkit.TestKitSupport

A http client for interacting with the service under test, the client will not be authenticated and will appear to the service as a request with the internet principal.

I

interpretEffects(Supplier<EventSourcedEntity.Effect<R>>, Metadata) - Method in class akka.javasdk.testkit.impl.EventSourcedEntityEffectsRunner

creates a command context to run the commands, then creates an event context to run the events, and finally, creates a command context to run the side effects.

isAsync() - Method in interface akka.javasdk.testkit.TimedActionResult

isDone() - Method in interface akka.javasdk.testkit.TimedActionResult

isError() - Method in interface akka.javasdk.testkit.EventSourcedResult

isError() - Method in interface akka.javasdk.testkit.KeyValueEntityResult

isError() - Method in interface akka.javasdk.testkit.TimedActionResult

isReply() - Method in interface akka.javasdk.testkit.EventSourcedResult

isReply() - Method in interface akka.javasdk.testkit.KeyValueEntityResult

K

KAFKA - Enum constant in enum class akka.javasdk.testkit.TestKit.Settings.EventingSupport

Used if you want to use an external Kafka broker on your tests.

KEY_VALUE_ENTITY - Static variable in class akka.javasdk.testkit.TestKit.MockedEventing

KeyValueEntityResult<R> - Interface in akka.javasdk.testkit

Represents the result of a KeyValueEntity handling a command when run in through the testkit.

KeyValueEntityTestKit<S,E> - Class in akka.javasdk.testkit

KeyValueEntity Testkit for use in unit tests for Value entities.

M

MessageBuilder(MessageCodec) - Constructor for class akka.javasdk.testkit.EventingTestKit.MessageBuilder

mockedEventing - Variable in class akka.javasdk.testkit.TestKit.Settings

MockRegistry - Interface in akka.javasdk.testkit

This trait is meant to allow for unit testing when a service has cross-component or cross-service calls.

O

of(String, Function<EventSourcedEntityContext, ES>) - Static method in class akka.javasdk.testkit.EventSourcedTestKit

Creates a new testkit instance from a user defined entity id and a function EventSourcedEntityContext to EventSourcedEntity.

of(String, Function<KeyValueEntityContext, E>) - Static method in class akka.javasdk.testkit.KeyValueEntityTestKit

Creates a new testkit instance from a user defined entity id and a function KeyValueEntityContext to KeyValueEntity.

of(String, Supplier<E>) - Static method in class akka.javasdk.testkit.KeyValueEntityTestKit

Creates a new testkit instance from a user defined entity id and a KeyValueEntity Supplier.

of(String, Supplier<ES>) - Static method in class akka.javasdk.testkit.EventSourcedTestKit

Creates a new testkit instance from a user defined entity id and an EventSourcedEntity Supplier.

of(Function<EventSourcedEntityContext, ES>) - Static method in class akka.javasdk.testkit.EventSourcedTestKit

Creates a new testkit instance from a function EventSourcedEntityContext to EventSourcedEntity.

of(Function<KeyValueEntityContext, E>) - Static method in class akka.javasdk.testkit.KeyValueEntityTestKit

Creates a new testkit instance from a function KeyValueEntityContext to KeyValueEntity.

of(Supplier<A>) - Static method in class akka.javasdk.testkit.TimedActionTestkit

of(Supplier<E>) - Static method in class akka.javasdk.testkit.KeyValueEntityTestKit

Creates a new testkit instance from a KeyValueEntity Supplier.

of(Supplier<ES>) - Static method in class akka.javasdk.testkit.EventSourcedTestKit

Creates a new testkit instance from a EventSourcedEntity Supplier.

of(T, Metadata) - Method in class akka.javasdk.testkit.EventingTestKit.MessageBuilder

Create a message object from a payload plus metadata.

of(T, String) - Method in class akka.javasdk.testkit.EventingTestKit.MessageBuilder

Create a message from a payload plus a subject (that is, the entity id).

P

publish(EventingTestKit.Message<?>) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages

Simulate the publishing of a message.

publish(ByteString) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages

Simulate the publishing of a raw message.

publish(ByteString, Metadata) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages

Simulate the publishing of a raw message.

publish(List<EventingTestKit.Message<?>>) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages

Publish multiple messages.

publish(T, String) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages

Simulate the publishing of a message.

publishDelete(String) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages

Publish a predefined delete message.

S

serviceName - Variable in class akka.javasdk.testkit.TestKit.Settings

The name of this service when deployed.

start() - Method in class akka.javasdk.testkit.TestKit

Start this testkit with default configuration.

start(ActorSystem<?>, String, int, MessageCodec) - Static method in interface akka.javasdk.testkit.EventingTestKit

INTERNAL API

stateWasDeleted() - Method in interface akka.javasdk.testkit.KeyValueEntityResult

stateWasUpdated() - Method in interface akka.javasdk.testkit.KeyValueEntityResult

stop() - Method in class akka.javasdk.testkit.TestKit

Stop the testkit and local runtime.

STREAM - Static variable in class akka.javasdk.testkit.TestKit.MockedEventing

T

TEST_BROKER - Enum constant in enum class akka.javasdk.testkit.TestKit.Settings.EventingSupport

This is the default type used and allows the testing eventing integrations without an external broker dependency running.

testKit - Variable in class akka.javasdk.testkit.TestKitSupport

TestKit - Class in akka.javasdk.testkit

Testkit for running services locally.

TestKit() - Constructor for class akka.javasdk.testkit.TestKit

Create a new testkit for a service descriptor with the default settings.

TestKit(TestKit.Settings) - Constructor for class akka.javasdk.testkit.TestKit

Create a new testkit for a service descriptor with custom settings.

TestKit.MockedEventing - Class in akka.javasdk.testkit

TestKit.Settings - Class in akka.javasdk.testkit

Settings for testkit.

TestKit.Settings.EventingSupport - Enum Class in akka.javasdk.testkit

TestkitExtension - Class in akka.javasdk.testkit.junit.jupiter

A JUnit 5 "Jupiter" Extension for TestKit, which automatically manages the lifecycle of the testkit.

TestkitExtension() - Constructor for class akka.javasdk.testkit.junit.jupiter.TestkitExtension

TestkitExtension(TestKit.Settings) - Constructor for class akka.javasdk.testkit.junit.jupiter.TestkitExtension

testKitSettings() - Method in class akka.javasdk.testkit.TestKitSupport

Override this to use custom settings for an integration test

TestKitSupport - Class in akka.javasdk.testkit

This class provided the necessary infrastructure to run integration test for projects built with the Java SDK.

TestKitSupport() - Constructor for class akka.javasdk.testkit.TestKitSupport

TimedActionResult - Interface in akka.javasdk.testkit

Represents the result of an Action handling a command when run in through the testkit.

TimedActionTestkit<A> - Class in akka.javasdk.testkit

TimedAction Testkit for use in unit tests for TimedActions.

timerScheduler - Variable in class akka.javasdk.testkit.TestKitSupport

toIncomingFlowConfig() - Method in class akka.javasdk.testkit.TestKit.MockedEventing

toOutgoingFlowConfig() - Method in class akka.javasdk.testkit.TestKit.MockedEventing

TOPIC - Static variable in class akka.javasdk.testkit.TestKit.MockedEventing

toString() - Method in class akka.javasdk.testkit.TestKit.MockedEventing

toString() - Method in class akka.javasdk.testkit.TestKit.Settings

V

valueOf(String) - Static method in enum class akka.javasdk.testkit.TestKit.Settings.EventingSupport

Returns the enum constant of this class with the specified name.

values() - Static method in enum class akka.javasdk.testkit.TestKit.Settings.EventingSupport

Returns an array containing the constants of this enum class, in the order they are declared.

W

withAclDisabled() - Method in class akka.javasdk.testkit.TestKit.Settings

Disable ACL checking in this service.

withAclEnabled() - Method in class akka.javasdk.testkit.TestKit.Settings

Enable ACL checking in this service (this is the default).

withAdditionalConfig(Config) - Method in class akka.javasdk.testkit.TestKit.Settings

Specify additional config that will override the application-test.conf or application.conf configuration in a particular test.

withDependencyProvider(DependencyProvider) - Method in class akka.javasdk.testkit.TestKit.Settings

Set a dependency provider that will be used for looking up arbitrary dependencies, useful to provide mocks for production dependencies in tests rather than calling the real thing.

withEventingSupport(TestKit.Settings.EventingSupport) - Method in class akka.javasdk.testkit.TestKit.Settings

withEventSourcedEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.Settings

Mock the incoming events flow from an EventSourcedEntity.

withEventSourcedIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.MockedEventing

withKeyValueEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.MockedEventing

withKeyValueEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.Settings

Mock the incoming messages flow from a KeyValueEntity.

withMock(Class<T>, T) - Method in interface akka.javasdk.testkit.MockRegistry

Returns a new MockRegistry with the new mock added to previous ones.

withServiceName(String) - Method in class akka.javasdk.testkit.TestKit.Settings

Set the name of this service.

withStreamIncomingMessages(String, String) - Method in class akka.javasdk.testkit.TestKit.MockedEventing

withStreamIncomingMessages(String, String) - Method in class akka.javasdk.testkit.TestKit.Settings

Mock the incoming messages flow from a Stream (eventing.in.direct in case of protobuf SDKs).

withTopicIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.MockedEventing

withTopicIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.Settings

Mock the incoming events flow from a Topic.

withTopicOutgoingMessages(String) - Method in class akka.javasdk.testkit.TestKit.MockedEventing

withTopicOutgoingMessages(String) - Method in class akka.javasdk.testkit.TestKit.Settings

Mock the outgoing events flow for a Topic.

A B C D E F G H I K M O P S T V W
All Classes and Interfaces|All Packages|Constant Field Values