Index

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

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
AiResponse(TestModelProvider.ToolInvocationRequest) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AiResponse
Constructs an AI response with only a tool request.
AiResponse(String) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AiResponse
Constructs an AI response with only a message.
AiResponse(String, TestModelProvider.ToolInvocationRequest) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AiResponse
Constructs an AI response with a message and a single tool request.
AiResponse(String, List<TestModelProvider.ToolInvocationRequest>) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AiResponse
Creates an instance of a AiResponse record class.
AiResponse(List<TestModelProvider.ToolInvocationRequest>) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AiResponse
Constructs an AI response with a list of tool invocation requests.
akka.javasdk.testkit - package akka.javasdk.testkit
 
akka.javasdk.testkit.junit.jupiter - package akka.javasdk.testkit.junit.jupiter
 
arguments() - Method in record class akka.javasdk.testkit.TestModelProvider.ToolInvocationRequest
Returns the value of the arguments record component.
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<E, KeyValueEntity.Effect<R>>) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit
Deprecated, for removal: This API element is subject to removal in a future version.
Use "method(MyEntity::myCommandHandler).invoke()" instead
call(Function<E, KeyValueEntity.Effect<R>>, Metadata) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit
Deprecated, for removal: This API element is subject to removal in a future version.
Use "method(MyEntity::myCommandHandler).withMetadata(metadata).invoke()" instead
call(Function<ES, EventSourcedEntity.Effect<R>>) - Method in class akka.javasdk.testkit.EventSourcedTestKit
Deprecated, for removal: This API element is subject to removal in a future version.
Use "method(MyEntity::myCommandHandler).invoke()" instead
call(Function<ES, EventSourcedEntity.Effect<R>>, Metadata) - Method in class akka.javasdk.testkit.EventSourcedTestKit
Deprecated, for removal: This API element is subject to removal in a future version.
Use "method(MyEntity::myCommandHandler).withMetadata(metadata).invoke()" instead
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.
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
 
content() - Method in interface akka.javasdk.testkit.TestModelProvider.InputMessage
 
content() - Method in record class akka.javasdk.testkit.TestModelProvider.ToolResult
Returns the value of the content record component.
content() - Method in record class akka.javasdk.testkit.TestModelProvider.UserMessage
Returns the value of the content record component.
create() - Static method in interface akka.javasdk.testkit.MockRegistry
Returns an empty instance of MockRegistry that can be chained with `withMock`
createChatModel() - Method in class akka.javasdk.testkit.TestModelProvider
 
createStreamingChatModel() - Method in class akka.javasdk.testkit.TestModelProvider
 

D

DEFAULT - Static variable in class akka.javasdk.testkit.TestKit.Settings
Default settings for testkit.
DEFAULT_TEST_ENTITY_ID - Static variable in class akka.javasdk.testkit.EventSourcedTestKit
 
defaultMetadata(Object, String) - Method in class akka.javasdk.testkit.EventingTestKit.MessageBuilder
Create a default metadata a given payload and subject.
DeferredCallDetails<I,O> - Interface in akka.javasdk.testkit
 
dependencyProvider - Variable in class akka.javasdk.testkit.TestKit.Settings
 
deserialize(Class<T>, byte[]) - Static method in class akka.javasdk.testkit.SerializationTestkit
 
didEmitEvents() - Method in interface akka.javasdk.testkit.EventSourcedResult
Deprecated, for removal: This API element is subject to removal in a future version.
didPersistEvents() - Method in interface akka.javasdk.testkit.EventSourcedResult
 
disabledComponents - Variable in class akka.javasdk.testkit.TestKit.Settings
 

E

EMPTY - Static variable in interface akka.javasdk.testkit.MockRegistry
 
EMPTY - Static variable in class akka.javasdk.testkit.TestKit.MockedEventing
 
entity - Variable in class akka.javasdk.testkit.EventSourcedTestKit
 
entity() - Method in class akka.javasdk.testkit.EventSourcedTestKit
 
equals(Object) - Method in record class akka.javasdk.testkit.TestModelProvider.AiResponse
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class akka.javasdk.testkit.TestModelProvider.ToolInvocationRequest
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class akka.javasdk.testkit.TestModelProvider.ToolResult
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class akka.javasdk.testkit.TestModelProvider.UserMessage
Indicates whether some other object is "equal to" this one.
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.
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.
EventSourcedTestKit.MethodRef<R> - Class in akka.javasdk.testkit
 
EventSourcedTestKit.MethodRef1<I,R> - Class in akka.javasdk.testkit
 
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.
failWith(RuntimeException) - Method in class akka.javasdk.testkit.TestModelProvider.WhenClause
Reply with a runtime exception for matching requests.
fixedResponse(String) - Method in class akka.javasdk.testkit.TestModelProvider
Configures a fixed response for all input messages.

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.
getAgentRegistry() - Method in class akka.javasdk.testkit.TestKit
 
getAllEvents() - Method in class akka.javasdk.testkit.EventSourcedTestKit
 
getAllEvents() - Method in interface akka.javasdk.testkit.EventSourcedResult
 
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
Lookup a specific object as provided by the service dependency provider
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(Class<? extends EventSourcedEntity<?, ?>>) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension
Get incoming messages for EventSourcedEntity.
getEventSourcedEntityIncomingMessages(Class<? extends EventSourcedEntity<?, ?>>) - Method in class akka.javasdk.testkit.TestKit
 
getEventSourcedEntityIncomingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit
 
getEventSourcedEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension
Deprecated, for removal: This API element is subject to removal in a future version.
getEventSourcedEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit
Deprecated, for removal: This API element is subject to removal in a future version.
getGrpcEndpointClient(Class<T>) - Method in class akka.javasdk.testkit.TestKit
Get a gRPC client for an endpoint provided by this service.
getGrpcEndpointClient(Class<T>) - Method in class akka.javasdk.testkit.TestKitSupport
Get a gRPC client for an endpoint provided by this service.
getGrpcEndpointClient(Class<T>, Principal) - Method in class akka.javasdk.testkit.TestKit
Get a gRPC client for an endpoint provided by this service but specify the client principal for the ACLs.
getGrpcEndpointClient(Class<T>, Principal) - Method in class akka.javasdk.testkit.TestKitSupport
Get a gRPC client for an endpoint provided by this service but specify the client principal for the ACLs.
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(Class<? extends KeyValueEntity<?>>) - Method in class akka.javasdk.testkit.TestKit
 
getKeyValueEntityIncomingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit
 
getKeyValueEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit
Deprecated, for removal: This API element is subject to removal in a future version.
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.
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.EventSourcedTestKit
 
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 Consume.ServiceStream.
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(Class<? extends KeyValueEntity<?>>) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension
Get incoming messages for ValueEntity.
getValueEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension
Deprecated, for removal: This API element is subject to removal in a future version.
getWorkflowIncomingMessages(Class<? extends Workflow<?>>) - Method in class akka.javasdk.testkit.junit.jupiter.TestkitExtension
Get incoming messages for Workflow.
getWorkflowIncomingMessages(Class<? extends Workflow<?>>) - Method in class akka.javasdk.testkit.TestKit
 
getWorkflowIncomingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit
 
getWorkflowIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit
Deprecated, for removal: This API element is subject to removal in a future version.
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
 
hasConfig() - Method in class akka.javasdk.testkit.TestKit.MockedEventing
 
hashCode() - Method in record class akka.javasdk.testkit.TestModelProvider.AiResponse
Returns a hash code value for this object.
hashCode() - Method in record class akka.javasdk.testkit.TestModelProvider.ToolInvocationRequest
Returns a hash code value for this object.
hashCode() - Method in record class akka.javasdk.testkit.TestModelProvider.ToolResult
Returns a hash code value for this object.
hashCode() - Method in record class akka.javasdk.testkit.TestModelProvider.UserMessage
Returns a hash code value for this object.
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>>, String, Metadata, Optional<Type>) - Method in class akka.javasdk.testkit.EventSourcedTestKit
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.
invoke() - Method in class akka.javasdk.testkit.EventSourcedTestKit.MethodRef
 
invoke() - Method in class akka.javasdk.testkit.KeyValueEntityTestKit.MethodRef
 
invoke(I) - Method in class akka.javasdk.testkit.EventSourcedTestKit.MethodRef1
 
invoke(I) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit.MethodRef1
 
isAsync() - Method in interface akka.javasdk.testkit.TimedActionResult
 
isDeleted() - Method in class akka.javasdk.testkit.EventSourcedTestKit
 
isDeleted() - Method in class akka.javasdk.testkit.KeyValueEntityTestKit
 
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.
KeyValueEntityTestKit.MethodRef<R> - Class in akka.javasdk.testkit
 
KeyValueEntityTestKit.MethodRef1<I,R> - Class in akka.javasdk.testkit
 

M

message() - Method in record class akka.javasdk.testkit.TestModelProvider.AiResponse
Returns the value of the message record component.
MessageBuilder(JsonSerializer) - Constructor for class akka.javasdk.testkit.EventingTestKit.MessageBuilder
 
method(Function<E, KeyValueEntity.Effect<R>>) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit
Pass in a Key Value Entity command handler method reference without parameters, e.g.
method(Function<ES, EventSourcedEntity.Effect<R>>) - Method in class akka.javasdk.testkit.EventSourcedTestKit
Pass in an Event Sourced Entity command handler method reference without parameters, e.g.
method(Function2<E, I, KeyValueEntity.Effect<R>>) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit
Pass in a Key Value Entity command handler method reference with a single parameter, e.g.
method(Function2<ES, I, EventSourcedEntity.Effect<R>>) - Method in class akka.javasdk.testkit.EventSourcedTestKit
Pass in an Event Sourced Entity command handler method reference with a single parameter, e.g.
MethodRef(Function<E, KeyValueEntity.Effect<R>>, Metadata) - Constructor for class akka.javasdk.testkit.KeyValueEntityTestKit.MethodRef
 
MethodRef(Function<ES, EventSourcedEntity.Effect<R>>, Metadata) - Constructor for class akka.javasdk.testkit.EventSourcedTestKit.MethodRef
 
MethodRef1(Function2<E, I, KeyValueEntity.Effect<R>>, Metadata) - Constructor for class akka.javasdk.testkit.KeyValueEntityTestKit.MethodRef1
 
MethodRef1(Function2<ES, I, EventSourcedEntity.Effect<R>>, Metadata) - Constructor for class akka.javasdk.testkit.EventSourcedTestKit.MethodRef1
 
MissingModelResponseException() - Constructor for exception class akka.javasdk.testkit.TestModelProvider.MissingModelResponseException
 
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.
modelProvidersByAgentId - Variable in class akka.javasdk.testkit.TestKit.Settings
 

N

name() - Method in record class akka.javasdk.testkit.TestModelProvider.ToolInvocationRequest
Returns the value of the name record component.
name() - Method in record class akka.javasdk.testkit.TestModelProvider.ToolResult
Returns the value of the name record component.

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).
ofEntityFromEvents(String, Function<EventSourcedEntityContext, ES>, List<E>) - Static method in class akka.javasdk.testkit.EventSourcedTestKit
Creates a new testkit instance from a user defined entity id, a factory function for EventSourcedEntity, and events from which to derive a state for the generated entity for tests.
ofEntityFromEvents(String, Supplier<ES>, List<E>) - Static method in class akka.javasdk.testkit.EventSourcedTestKit
Creates a new testkit instance from a user defined entity id, a Supplier of EventSourcedEntity, and events from which to derive a state for the generated entity for tests.
ofEntityFromEvents(Function<EventSourcedEntityContext, ES>, List<E>) - Static method in class akka.javasdk.testkit.EventSourcedTestKit
Creates a new testkit instance from a factory function for EventSourcedEntity and events from which to derive a state for the generated entity for tests.
ofEntityFromEvents(Supplier<ES>, List<E>) - Static method in class akka.javasdk.testkit.EventSourcedTestKit
Creates a new testkit instance from a Supplier of EventSourcedEntity and events from which to derive a state for the generated entity.
ofEntityWithState(String, Function<EventSourcedEntityContext, ES>, S) - Static method in class akka.javasdk.testkit.EventSourcedTestKit
Creates a new testkit instance from a user defined entity id, a factory function for EventSourcedEntity, and a state into which the built entity will be placed for tests.
ofEntityWithState(String, Supplier<ES>, S) - Static method in class akka.javasdk.testkit.EventSourcedTestKit
Creates a new testkit instance from a user defined entity id, a Supplier of EventSourcedEntity, and a state into which the supplied entity will be placed for tests.
ofEntityWithState(Function<EventSourcedEntityContext, ES>, S) - Static method in class akka.javasdk.testkit.EventSourcedTestKit
Creates a new testkit instance from a factory function for EventSourcedEntity and a state into which the built entity will be placed for tests.
ofEntityWithState(Supplier<ES>, S) - Static method in class akka.javasdk.testkit.EventSourcedTestKit
Creates a new testkit instance from a Supplier of EventSourcedEntity and a state.

P

publish(byte[]) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages
Simulate the publishing of a raw message.
publish(byte[], Metadata) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages
Simulate the publishing of a raw message.
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
Deprecated.
Use publish with byte array parameter
publish(ByteString, Metadata) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages
Deprecated.
Use publish with byte array parameter
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.

R

reply(TestModelProvider.AiResponse) - Method in class akka.javasdk.testkit.TestModelProvider.WhenClause
Reply with a custom AI response for matching requests.
reply(TestModelProvider.ToolInvocationRequest) - Method in class akka.javasdk.testkit.TestModelProvider.WhenClause
Reply with a tool invocation request for matching requests.
reply(String) - Method in class akka.javasdk.testkit.TestModelProvider.WhenClause
Reply with a simple message for matching requests.
reply(List<TestModelProvider.ToolInvocationRequest>) - Method in class akka.javasdk.testkit.TestModelProvider.WhenClause
Reply with a list of tool invocation requests for matching requests.
reset() - Method in class akka.javasdk.testkit.TestModelProvider
Resets all previously added response configurations.

S

SerializationTestkit - Class in akka.javasdk.testkit
Helper class for serializing and deserializing objects for testing schema migration.
SerializationTestkit() - Constructor for class akka.javasdk.testkit.SerializationTestkit
 
serialize(T) - Static method in class akka.javasdk.testkit.SerializationTestkit
 
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, JsonSerializer) - 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
 
TestModelProvider - Class in akka.javasdk.testkit
A ModelProvider implementation for testing purposes that does not use a real AI model.
TestModelProvider() - Constructor for class akka.javasdk.testkit.TestModelProvider
 
TestModelProvider.AiResponse - Record Class in akka.javasdk.testkit
Represents an AI response, which can include a message and/or list of tool invocation requests.
TestModelProvider.InputMessage - Interface in akka.javasdk.testkit
Represents an input message.
TestModelProvider.MissingModelResponseException - Exception Class in akka.javasdk.testkit
 
TestModelProvider.ToolInvocationRequest - Record Class in akka.javasdk.testkit
Represents a tool invocation request with a name and arguments.
TestModelProvider.ToolResult - Record Class in akka.javasdk.testkit
Represents a tool result.
TestModelProvider.UserMessage - Record Class in akka.javasdk.testkit
Represents a user message.
TestModelProvider.WhenClause - Class in akka.javasdk.testkit
Base class for building reply configurations for specific input predicates.
TestModelProvider.WhenToolReplyClause - Class in akka.javasdk.testkit
Specialized reply builder for handling tool result messages.
thenReply(Function<TestModelProvider.ToolResult, TestModelProvider.AiResponse>) - Method in class akka.javasdk.testkit.TestModelProvider.WhenToolReplyClause
Configures a reply with a custom handler for a tool result message.
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
 
ToolInvocationRequest(String, String) - Constructor for record class akka.javasdk.testkit.TestModelProvider.ToolInvocationRequest
Creates an instance of a ToolInvocationRequest record class.
toolRequests() - Method in record class akka.javasdk.testkit.TestModelProvider.AiResponse
Returns the value of the toolRequests record component.
ToolResult(String, String) - Constructor for record class akka.javasdk.testkit.TestModelProvider.ToolResult
Creates an instance of a ToolResult record class.
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
 
toString() - Method in record class akka.javasdk.testkit.TestModelProvider.AiResponse
Returns a string representation of this record class.
toString() - Method in record class akka.javasdk.testkit.TestModelProvider.ToolInvocationRequest
Returns a string representation of this record class.
toString() - Method in record class akka.javasdk.testkit.TestModelProvider.ToolResult
Returns a string representation of this record class.
toString() - Method in record class akka.javasdk.testkit.TestModelProvider.UserMessage
Returns a string representation of this record class.

U

UserMessage(String) - Constructor for record class akka.javasdk.testkit.TestModelProvider.UserMessage
Creates an instance of a UserMessage record class.

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

WhenClause(TestModelProvider, Predicate<TestModelProvider.InputMessage>) - Constructor for class akka.javasdk.testkit.TestModelProvider.WhenClause
 
whenMessage(String) - Method in class akka.javasdk.testkit.TestModelProvider
Configures to respond when the content of an TestModelProvider.InputMessage is an exact match of the passed message.
whenMessage(Predicate<String>) - Method in class akka.javasdk.testkit.TestModelProvider
Configures to respond when the passed string predicate matches the content of an TestModelProvider.InputMessage.
WhenToolReplyClause(TestModelProvider, Predicate<TestModelProvider.InputMessage>) - Constructor for class akka.javasdk.testkit.TestModelProvider.WhenToolReplyClause
 
whenToolResult(TestModelProvider.ToolResult) - Method in class akka.javasdk.testkit.TestModelProvider
Configures to respond when an TestModelProvider.ToolResult is an exact match of toolResult.
whenToolResult(Predicate<TestModelProvider.ToolResult>) - Method in class akka.javasdk.testkit.TestModelProvider
Configures to respond when the given predicate matches a TestModelProvider.ToolResult.
whenUserMessage(TestModelProvider.UserMessage) - Method in class akka.javasdk.testkit.TestModelProvider
Configures to respond when an TestModelProvider.UserMessage is an exact match of userMessage.
whenUserMessage(Predicate<TestModelProvider.UserMessage>) - Method in class akka.javasdk.testkit.TestModelProvider
Configures to respond when the given predicate matches a TestModelProvider.UserMessage.
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.
withAdditionalConfig(String) - 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.
withDisabledComponents(Set<Class<?>>) - Method in class akka.javasdk.testkit.TestKit.Settings
Disable components from running, useful for testing components in isolation.
withEventingSupport(TestKit.Settings.EventingSupport) - Method in class akka.javasdk.testkit.TestKit.Settings
 
withEventSourcedEntityIncomingMessages(Class<? extends EventSourcedEntity<?, ?>>) - Method in class akka.javasdk.testkit.TestKit.Settings
 
withEventSourcedEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.Settings
Deprecated, for removal: This API element is subject to removal in a future version.
withEventSourcedIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.MockedEventing
 
withKeyValueEntityIncomingMessages(Class<? extends KeyValueEntity<?>>) - Method in class akka.javasdk.testkit.TestKit.Settings
 
withKeyValueEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.MockedEventing
 
withKeyValueEntityIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.Settings
Deprecated, for removal: This API element is subject to removal in a future version.
withMetadata(Metadata) - Method in class akka.javasdk.testkit.EventSourcedTestKit.MethodRef
 
withMetadata(Metadata) - Method in class akka.javasdk.testkit.EventSourcedTestKit.MethodRef1
 
withMetadata(Metadata) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit.MethodRef
 
withMetadata(Metadata) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit.MethodRef1
 
withMock(Class<T>, T) - Method in interface akka.javasdk.testkit.MockRegistry
Returns a new MockRegistry with the new mock added to previous ones.
withModelProvider(Class<? extends Agent>, ModelProvider) - Method in class akka.javasdk.testkit.TestKit.Settings
 
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.
withWorkflowIncomingMessages(Class<? extends Workflow<?>>) - Method in class akka.javasdk.testkit.TestKit.Settings
 
withWorkflowIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.MockedEventing
 
withWorkflowIncomingMessages(String) - Method in class akka.javasdk.testkit.TestKit.Settings
Deprecated, for removal: This API element is subject to removal in a future version.
WORKFLOW - Static variable in class akka.javasdk.testkit.TestKit.MockedEventing
 
A B C D E F G H I K M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form