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

accessKeyId - Variable in class akka.javasdk.testkit.ObjectStorageBucketConfig.S3StaticCredentials
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
agentClass() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.TeamMemberSpec: Returns the value of the agentClass record component.
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>, Optional<Agent.TokenUsage>) - 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.
as() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ParticipantRef: Returns the value of the as 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
broadcast(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the broadcast tool.
BROADCAST - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for broadcasting a message to a conversation.

C

call(Function<A, TimedAction.Effect>) - Method in class akka.javasdk.testkit.TimedActionTestkit: Deprecated, for removal: This API element is subject to removal in a future version.
Use "method(MyTimedAction::myCommandHandler).invoke()" instead
call(Function<A, TimedAction.Effect>, Metadata) - Method in class akka.javasdk.testkit.TimedActionTestkit: Deprecated, for removal: This API element is subject to removal in a future version.
Use "method(MyTimedAction::myCommandHandler).withMetadata(metadata).invoke()" instead
CANCEL_UNCLAIMED_TASKS_FROM_BACKLOG - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for cancelling unclaimed tasks from backlog (lead side).
cancelUnclaimedTasksFromBacklog() - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the cancel_unclaimed_tasks_from_backlog tool.
cancelUnclaimedTasksFromBacklog(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the cancel_unclaimed_tasks_from_backlog tool with a specific backlog ID.
CLAIM_TASK - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for claiming a task (member side).
claimTask(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the claim_task tool.
claimTask(String, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the claim_task tool with a specific backlog ID.
clear() - Method in interface akka.javasdk.testkit.EventingTestKit.OutgoingMessages: Clear the destination so any existing messages are not considered on subsequent expect call.
clear() - Method in class akka.javasdk.testkit.TestNotificationPublisher: Clears all collected notifications.
COMPLETE_TASK - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for completing a task.
completeTask(Object) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the complete_task tool, serializing the given result object to JSON.
completeTaskJson(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the complete_task tool, with the given raw result JSON string.
componentClient - Variable in class akka.javasdk.testkit.TestKitSupport
ConsumerResult - Interface in akka.javasdk.testkit: Represents the result of a Consumer handling a message when run through the testkit.
ConsumerTestKit<C> - Class in akka.javasdk.testkit: Consumer Testkit for use in unit tests for Consumers.
ConsumerTestKit.MethodRef - Class in akka.javasdk.testkit
ConsumerTestKit.MethodRef1<I> - Class in akka.javasdk.testkit
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
contents() - Method in record class akka.javasdk.testkit.TestModelProvider.UserMessage: Returns the value of the contents record component.
count() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.TeamMemberSpec: Returns the value of the count record component.
create() - Static method in interface akka.javasdk.testkit.MockRegistry: Returns an empty instance of MockRegistry that can be chained with `withMock`
CREATE_TEAM - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for creating a team.
createChatModel() - Method in class akka.javasdk.testkit.TestModelProvider
createStreamingChatModel() - Method in class akka.javasdk.testkit.TestModelProvider
createTaskForBacklog(Task<?>, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for a create_<taskType>_task_for_backlog tool.
createTaskForBacklog(Task<?>, String, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for a create_<taskType>_task_for_backlog tool with a specific backlog ID.
createTaskForBacklog(TaskTemplate<?>, String, Map<String, String>) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for a create_<taskType>_task_for_backlog tool with a specific backlog ID, filling template parameters for a TaskTemplate.
createTaskForBacklog(TaskTemplate<?>, Map<String, String>) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for a create_<taskType>_task_for_backlog tool, filling template parameters for a TaskTemplate.
createTaskForBacklogToolName(TaskDefinition<?>) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Returns the tool name for a create_<taskType>_task_for_backlog tool, derived from the task definition name.
createTeam(TestModelProvider.AutonomousAgentTools.TeamMemberSpec...) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the create_team tool.

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
DEFAULT_TEST_ENTITY_ID - Static variable in class akka.javasdk.testkit.KeyValueEntityTestKit
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
delegateTo(Task<?>, Class<? extends AutonomousAgent>, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for a delegate_<task>_to_<agent> tool, deriving the tool name from the task definition and the target agent's component ID.
delegateTo(TaskTemplate<?>, Class<? extends AutonomousAgent>, Map<String, String>) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for a delegate_<task>_to_<agent> tool, filling template parameters for a TaskTemplate.
delegateTo(Class<? extends Agent>, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for a delegate_to_<agent> tool, used when an autonomous agent delegates to a request-based agent.
delegateToToolName(TaskDefinition<?>, Class<? extends AutonomousAgent>) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Returns the tool name for a delegate_<task>_to_<agent> tool, derived from the task definition and target agent's component ID.
delegateToToolName(Class<? extends Agent>) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Returns the tool name for a delegate_to_<agent> tool for request-based agent delegation, derived from the target agent's component ID.
dependencyProvider - Variable in class akka.javasdk.testkit.TestKit.Settings
deserialize(Class<T>, byte[]) - Static method in class akka.javasdk.testkit.SerializationTestkit: Deserialize bytes to the expected type.
didPersistEvents() - Method in interface akka.javasdk.testkit.EventSourcedResult
direct(String, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the direct tool (directed mode only).
DIRECT - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for directing a participant in a conversation (directed mode).
disabledComponents - Variable in class akka.javasdk.testkit.TestKit.Settings
DISBAND_TEAM - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for disbanding a team.
disbandTeam() - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the disband_team tool.
disbandTeam(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the disband_team tool with a specific team ID.

E

EMPTY - Static variable in interface akka.javasdk.testkit.MockRegistry
EMPTY - Static variable in class akka.javasdk.testkit.TestKit.MockedEventing
END_CONVERSATION - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for ending a moderated conversation (directed mode).
endConversation() - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the end_conversation tool (directed mode only).
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.AutonomousAgentTools.ParticipantRef: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ScriptStep: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.TeamMemberSpec: 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.
equals(Object) - Method in record class akka.javasdk.testkit.WebSocketRouteTester.WsConnection: 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.
extractContacts(TestModelProvider.InputMessage) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Extracts messaging contact addresses from input messages.

F

FAIL_TASK - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for failing a task.
failed(CompletionStage<O>) - Method in class akka.javasdk.testkit.AsyncCallsSupport: If completed with an exception, returns the exception.
failTask(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the fail_task tool.
failWith(RuntimeException) - Method in class akka.javasdk.testkit.TestModelProvider.WhenClause: Reply with a runtime exception for matching requests.
filesystem(String) - Static method in interface akka.javasdk.testkit.ObjectStorageBucketConfig: Filesystem-backed bucket.
filesystem(String, String) - Static method in interface akka.javasdk.testkit.ObjectStorageBucketConfig: Filesystem-backed bucket with an explicit storage directory.
fixedResponse(TestModelProvider.AiResponse) - Method in class akka.javasdk.testkit.TestModelProvider: Configures a fixed TestModelProvider.AiResponse for all input messages.
fixedResponse(TestModelProvider.ToolInvocationRequest) - Method in class akka.javasdk.testkit.TestModelProvider: Configures a fixed tool invocation response for all input messages.
fixedResponse(String) - Method in class akka.javasdk.testkit.TestModelProvider: Configures a fixed response for all input messages.
fixedResponse(Function<TestModelProvider.InputMessage, TestModelProvider.AiResponse>) - Method in class akka.javasdk.testkit.TestModelProvider: Configures a dynamic response for each input message.

G

gcs(String, String, ObjectStorageBucketConfig.GcsCredentials) - Static method in interface akka.javasdk.testkit.ObjectStorageBucketConfig: GCS-backed bucket (Google Cloud Storage).
GcsServiceAccountKeyCredentials(String) - Constructor for class akka.javasdk.testkit.ObjectStorageBucketConfig.GcsServiceAccountKeyCredentials
GET_BACKLOG_STATUS - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for getting backlog status (member side).
GET_MANAGED_BACKLOG_STATUS - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for getting managed backlog status (lead side).
GET_TASK - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for looking up a task by ID.
GET_TEAM_STATUS - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for getting team status.
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
getAgents(String) - Method in class akka.javasdk.testkit.TelemetryReader: Retrieves the list of agents that were invoked during an operation.
getAgentTools(String) - Method in class akka.javasdk.testkit.TelemetryReader: Retrieves the list of tools used by agents during an operation.
getAllEvents() - Method in class akka.javasdk.testkit.EventSourcedTestKit
getAllEvents() - Method in interface akka.javasdk.testkit.EventSourcedResult
getApplicationConfig() - Method in class akka.javasdk.testkit.TestKit
getBacklogStatus() - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the get_backlog_status tool.
getBacklogStatus(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the get_backlog_status tool with a specific backlog ID.
getComponentClient() - Method in class akka.javasdk.testkit.TestKit: Get an ComponentClient for interacting "internally" with the components of a service.
getComponentDescription(Class<?>) - Static method in class akka.javasdk.testkit.TestKit: Utility method to get the component description from a component class.
getComponentIdValue(Class<?>) - Static method in class akka.javasdk.testkit.TestKit: Utility method to get the component ID from a component class.
getComponentName(Class<?>) - Static method in class akka.javasdk.testkit.TestKit: Utility method to get the component name from a component class.
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: Get incoming messages for EventSourcedEntity.
getEventSourcedEntityIncomingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit
getExpireAfter() - Method in interface akka.javasdk.testkit.EventSourcedResult
getExpireAfter() - Method in interface akka.javasdk.testkit.KeyValueEntityResult
getGrpcClientProvider() - Method in class akka.javasdk.testkit.TestKit: Get a GrpcClientProvider for looking up gRPC clients to interact with services other than the current.
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.
getInMemorySpanExporter() - Method in class akka.javasdk.testkit.TestKit
getKeyValueEntityIncomingMessages(Class<? extends KeyValueEntity<?>>) - Method in class akka.javasdk.testkit.TestKit: Get incoming messages for KeyValueEntity.
getKeyValueEntityIncomingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit
getManagedBacklogStatus() - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the get_managed_backlog_status tool.
getManagedBacklogStatus(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the get_managed_backlog_status tool with a specific backlog ID.
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.ConsumerResult
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
getMockedGrpcServices() - Method in class akka.javasdk.testkit.TestKit: Registry for managing gRPC service mocks on the running testkit.
getMockedHttpServices() - Method in class akka.javasdk.testkit.TestKit: Registry for managing HTTP service mocks on the running testkit.
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.
getNotifications() - Method in class akka.javasdk.testkit.TestNotificationPublisher: Returns a list of all notifications published so far, in order.
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.
getProducedMessage() - Method in interface akka.javasdk.testkit.ConsumerResult
getProducedMessage(Class<T>) - Method in interface akka.javasdk.testkit.ConsumerResult: Returns the produced message payload, verifying its type.
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
getSanitizer() - Method in class akka.javasdk.testkit.TestKit
getSanitizer() - Method in class akka.javasdk.testkit.TestKitSupport
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.
getSelfSseRouteTester() - Method in class akka.javasdk.testkit.TestKit
getSelfWebSocketRouteTester() - Method in class akka.javasdk.testkit.TestKit
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.
getStreamOutgoingMessages(String, String) - Method in interface akka.javasdk.testkit.EventingTestKit
getStreamOutgoingMessages(String, String) - Method in class akka.javasdk.testkit.TestKit: Get outgoing messages produced by a @Produce.ServiceStream producer in the service under test.
getTask(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the get_task tool.
getTeamStatus() - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the get_team_status tool.
getTeamStatus(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the get_team_status tool with a specific team ID.
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.
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: Get incoming messages for Workflow.
getWorkflowIncomingMessages(String) - Method in interface akka.javasdk.testkit.EventingTestKit
getWorkflowSteps(Class<? extends Workflow<?>>, String) - Method in class akka.javasdk.testkit.TelemetryReader: Retrieves the sequence of workflow steps executed for a specific workflow instance.
getWorkflowSteps(String) - Method in class akka.javasdk.testkit.TelemetryReader: Retrieves the sequence of workflow steps executed for an operation traced by a debug ID.
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.
grpcMocks - Variable in class akka.javasdk.testkit.TestKit.Settings: Map from service name to a map of gRPC service client class -> mock instance, used to mock gRPC service calls for the given service name.
guidance() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ScriptStep: Returns the value of the guidance record component.

H

handleEvent(S, E) - Method in class akka.javasdk.testkit.EventSourcedTestKit
handoffTo(Class<? extends AutonomousAgent>, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for a handoff_to_<agent> tool, deriving the tool name from the target agent's component ID.
handoffToToolName(Class<? extends AutonomousAgent>) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Returns the tool name for a handoff_to_<agent> tool, derived from the target agent's component ID.
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.AutonomousAgentTools.ParticipantRef: Returns a hash code value for this object.
hashCode() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ScriptStep: Returns a hash code value for this object.
hashCode() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.TeamMemberSpec: 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.
hashCode() - Method in record class akka.javasdk.testkit.WebSocketRouteTester.WsConnection: Returns a hash code value for this object.
hasIncomingConfig() - Method in class akka.javasdk.testkit.TestKit.MockedEventing
hasMetadata() - Method in interface akka.javasdk.testkit.ConsumerResult
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.
httpMocks - Variable in class akka.javasdk.testkit.TestKit.Settings: Map from service name to a synchronous HTTP request handler that mocks responses for that service.

I

INSTANCE - Enum constant in enum class akka.javasdk.testkit.ObjectStorageBucketConfig.GcsWorkloadIdentity
INSTANCE - Enum constant in enum class akka.javasdk.testkit.ObjectStorageBucketConfig.S3WorkloadIdentity
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.ConsumerTestKit.MethodRef
invoke() - Method in class akka.javasdk.testkit.EventSourcedTestKit.MethodRef
invoke() - Method in class akka.javasdk.testkit.KeyValueEntityTestKit.MethodRef
invoke() - Method in class akka.javasdk.testkit.TimedActionTestkit.MethodRef
invoke(I) - Method in class akka.javasdk.testkit.ConsumerTestKit.MethodRef1
invoke(I) - Method in class akka.javasdk.testkit.EventSourcedTestKit.MethodRef1
invoke(I) - Method in class akka.javasdk.testkit.KeyValueEntityTestKit.MethodRef1
invoke(I) - Method in class akka.javasdk.testkit.TimedActionTestkit.MethodRef1
isAsync() - Method in interface akka.javasdk.testkit.TimedActionResult
isConsumed() - Method in interface akka.javasdk.testkit.ConsumerResult
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
isProduced() - Method in interface akka.javasdk.testkit.ConsumerResult
isReply() - Method in interface akka.javasdk.testkit.EventSourcedResult
isReply() - Method in interface akka.javasdk.testkit.KeyValueEntityResult
isTextOnly() - Method in record class akka.javasdk.testkit.TestModelProvider.UserMessage

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(Serializer) - Constructor for class akka.javasdk.testkit.EventingTestKit.MessageBuilder
method(Function<A, TimedAction.Effect>) - Method in class akka.javasdk.testkit.TimedActionTestkit: Pass in a Timed Action command handler method reference without parameters, e.g.
method(Function<C, Consumer.Effect>) - Method in class akka.javasdk.testkit.ConsumerTestKit: Pass in a Consumer message handler method reference without parameters, e.g.
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<A, I, TimedAction.Effect>) - Method in class akka.javasdk.testkit.TimedActionTestkit: Pass in a Timed Action command handler method reference with a single parameter, e.g.
method(Function2<C, I, Consumer.Effect>) - Method in class akka.javasdk.testkit.ConsumerTestKit: Pass in a Consumer message handler method reference with a single parameter, 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<A, TimedAction.Effect>, Metadata) - Constructor for class akka.javasdk.testkit.TimedActionTestkit.MethodRef
MethodRef(Function<C, Consumer.Effect>, Metadata) - Constructor for class akka.javasdk.testkit.ConsumerTestKit.MethodRef
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<A, I, TimedAction.Effect>, Metadata) - Constructor for class akka.javasdk.testkit.TimedActionTestkit.MethodRef1
MethodRef1(Function2<C, I, Consumer.Effect>, Metadata) - Constructor for class akka.javasdk.testkit.ConsumerTestKit.MethodRef1
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
MockedGrpcServices - Interface in akka.javasdk.testkit: Registry of mocked gRPC services for a running TestKit.
MockedHttpServices - Interface in akka.javasdk.testkit: Registry of mocked HTTP services for a running TestKit.
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.
mockResponse(String, Class<T>, T) - Method in interface akka.javasdk.testkit.MockedGrpcServices: Register or replace a mock instance for calls made through grpcClientProvider.grpcClientFor(serviceClass, serviceName).
mockResponse(String, Function<HttpRequest, HttpResponse>) - Method in interface akka.javasdk.testkit.MockedHttpServices: Register or replace a mock handler for calls made through httpClientProvider.httpClientFor(serviceName).
modelName() - Method in class akka.javasdk.testkit.TestModelProvider
modelProvidersByAgentId - Variable in class akka.javasdk.testkit.TestKit.Settings

N

name() - Method in interface akka.javasdk.testkit.ObjectStorageBucketConfig: The logical bucket name as used in SDK calls.
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

ObjectStorageBucketConfig - Interface in akka.javasdk.testkit: Configuration for a named object-storage bucket used in integration tests / dev mode.
ObjectStorageBucketConfig.GcsCredentials - Interface in akka.javasdk.testkit: Credentials for a GCS-backed bucket.
ObjectStorageBucketConfig.GcsServiceAccountKeyCredentials - Class in akka.javasdk.testkit: GCS service-account key file credentials.
ObjectStorageBucketConfig.GcsWorkloadIdentity - Enum Class in akka.javasdk.testkit: GCP Application Default Credentials (workload identity / ADC).
ObjectStorageBucketConfig.Impl - Class in akka.javasdk.testkit: Not part of the public API.
ObjectStorageBucketConfig.S3Credentials - Interface in akka.javasdk.testkit: Credentials for an S3-backed bucket.
ObjectStorageBucketConfig.S3ProfileCredentials - Class in akka.javasdk.testkit: AWS named-profile credentials (reads from ~/.aws/credentials).
ObjectStorageBucketConfig.S3StaticCredentials - Class in akka.javasdk.testkit: Static AWS credentials (access key + secret).
ObjectStorageBucketConfig.S3WorkloadIdentity - Enum Class in akka.javasdk.testkit: AWS workload-identity / instance-profile credentials.
objectStorageBuckets - Variable in class akka.javasdk.testkit.TestKit.Settings
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<C>) - Static method in class akka.javasdk.testkit.ConsumerTestKit
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, Function<KeyValueEntityContext, E>, S) - 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, starting with the given initial state instead of the entity's emptyState().
ofEntityWithState(String, Supplier<E>, S) - Static method in class akka.javasdk.testkit.KeyValueEntityTestKit: Creates a new testkit instance from a user defined entity id and a KeyValueEntity Supplier, starting with the given initial state instead of the entity's emptyState().
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(Function<KeyValueEntityContext, E>, S) - Static method in class akka.javasdk.testkit.KeyValueEntityTestKit: Creates a new testkit instance from a function KeyValueEntityContext to KeyValueEntity, starting with the given initial state instead of the entity's emptyState().
ofEntityWithState(Supplier<E>, S) - Static method in class akka.javasdk.testkit.KeyValueEntityTestKit: Creates a new testkit instance from a KeyValueEntity Supplier, starting with the given initial state instead of the entity's emptyState().
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.
overrideDisabledComponents - Variable in class akka.javasdk.testkit.TestKit.Settings: When true, the testkit disabled components override any disabled components from ServiceSetup, rather than being combined with them.

P

ParticipantRef(String) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ParticipantRef
ParticipantRef(String, String) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ParticipantRef: Creates an instance of a ParticipantRef record class.
path - Variable in class akka.javasdk.testkit.ObjectStorageBucketConfig.GcsServiceAccountKeyCredentials
profileName - Variable in class akka.javasdk.testkit.ObjectStorageBucketConfig.S3ProfileCredentials
PROVIDE_PROMPT - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for providing a prompt during a scripted conversation step.
providePrompt(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the provide_prompt tool (scripted mode).
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(List<EventingTestKit.Message<?>>) - Method in interface akka.javasdk.testkit.EventingTestKit.IncomingMessages: Publish multiple messages.
publish(T) - Method in class akka.javasdk.testkit.TestNotificationPublisher
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.
publisher() - Method in record class akka.javasdk.testkit.WebSocketRouteTester.WsConnection: Returns the value of the publisher record component.

R

receiveFirstN(String, int, Duration) - Method in interface akka.javasdk.testkit.SseRouteTester
receiveNFromOffset(String, int, String, Duration) - Method in interface akka.javasdk.testkit.SseRouteTester
RELEASE_TASK - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for releasing a task (member side).
releaseTask(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the release_task tool.
releaseTask(String, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the release_task tool with a specific backlog ID.
remove(String) - Method in interface akka.javasdk.testkit.MockedHttpServices: Remove the mock for the given service name, if any.
remove(String, Class<T>) - Method in interface akka.javasdk.testkit.MockedGrpcServices: Remove the mock for the given service name and client class, if any.
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(String, Agent.TokenUsage) - Method in class akka.javasdk.testkit.TestModelProvider.WhenClause: Reply with a simple message for matching requests with defined token usage.
reply(Function<TestModelProvider.InputMessage, TestModelProvider.AiResponse>) - Method in class akka.javasdk.testkit.TestModelProvider.WhenClause: Reply dynamically based on the input message.
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 interface akka.javasdk.testkit.MockedGrpcServices: Reset the registry back to the mocks declared in TestKit.Settings.
reset() - Method in interface akka.javasdk.testkit.MockedHttpServices: Reset the registry back to the mocks declared in TestKit.Settings.
reset() - Method in class akka.javasdk.testkit.TestModelProvider: Resets all previously added response configurations.

S

s3(String, String, String, ObjectStorageBucketConfig.S3Credentials) - Static method in interface akka.javasdk.testkit.ObjectStorageBucketConfig: S3-backed bucket (Amazon S3 or S3-compatible, e.g.
S3ProfileCredentials(String) - Constructor for class akka.javasdk.testkit.ObjectStorageBucketConfig.S3ProfileCredentials
S3StaticCredentials(String, String) - Constructor for class akka.javasdk.testkit.ObjectStorageBucketConfig.S3StaticCredentials
ScriptStep(String, String) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ScriptStep: Creates an instance of a ScriptStep record class.
secretAccessKey - Variable in class akka.javasdk.testkit.ObjectStorageBucketConfig.S3StaticCredentials
SEND_MESSAGE - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for sending a message to another agent.
sendMessage(String, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the send_message tool.
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: Serialize a value to bytes.
serviceName - Variable in class akka.javasdk.testkit.TestKit.Settings: The name of this service when deployed.
speaker() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ScriptStep: Returns the value of the speaker record component.
SseRouteTester - Interface in akka.javasdk.testkit
start() - Method in class akka.javasdk.testkit.TestKit: Start this testkit with default configuration.
START_CONVERSATION - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for starting a moderated conversation.
startDirectedConversation(String, int, List<TestModelProvider.AutonomousAgentTools.ParticipantRef>) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the start_conversation tool with a directed pattern.
startScriptedConversation(String, List<TestModelProvider.AutonomousAgentTools.ParticipantRef>, List<TestModelProvider.AutonomousAgentTools.ScriptStep>) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the start_conversation tool with a scripted pattern.
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
SUBMIT_TURN - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for submitting a turn response.
submitTurn(String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the submit_turn tool.
subscriber() - Method in record class akka.javasdk.testkit.WebSocketRouteTester.WsConnection: Returns the value of the subscriber record component.

T

TeamMemberSpec(Class<?>) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.TeamMemberSpec
TeamMemberSpec(Class<?>, int) - Constructor for record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.TeamMemberSpec: Creates an instance of a TeamMemberSpec record class.
telemetryReader - Variable in class akka.javasdk.testkit.TestKitSupport
TelemetryReader - Class in akka.javasdk.testkit: A test utility for reading and inspecting telemetry data captured during test execution.
TelemetryReader(TracingSetup.AkkaInMemorySpanExporter) - Constructor for class akka.javasdk.testkit.TelemetryReader
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.AutonomousAgentTools - Class in akka.javasdk.testkit: Factory methods for TestModelProvider.ToolInvocationRequest instances that correspond to the internal tools exposed by the autonomous agent runtime to the LLM.
TestModelProvider.AutonomousAgentTools.ParticipantRef - Record Class in akka.javasdk.testkit: Participant reference for scripted conversations, with type and reference name.
TestModelProvider.AutonomousAgentTools.ScriptStep - Record Class in akka.javasdk.testkit: A step in a scripted conversation, specifying speaker and guidance.
TestModelProvider.AutonomousAgentTools.TeamMemberSpec - Record Class in akka.javasdk.testkit: Specifies a team member type and count for a create_team tool invocation.
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.
TestNotificationPublisher<T> - Class in akka.javasdk.testkit: Test implementation of NotificationPublisher that collects all published notifications for later assertions.
TestNotificationPublisher() - Constructor for class akka.javasdk.testkit.TestNotificationPublisher
text() - Method in record class akka.javasdk.testkit.TestModelProvider.UserMessage
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.
TimedActionTestkit.MethodRef - Class in akka.javasdk.testkit
TimedActionTestkit.MethodRef1<I> - Class in akka.javasdk.testkit
timerScheduler - Variable in class akka.javasdk.testkit.TestKitSupport
toIncomingFlowConfig() - Method in class akka.javasdk.testkit.TestKit.MockedEventing
tokenUsage() - Method in record class akka.javasdk.testkit.TestModelProvider.AiResponse: Returns the value of the tokenUsage record component.
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.AutonomousAgentTools.ParticipantRef: Returns a string representation of this record class.
toString() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ScriptStep: Returns a string representation of this record class.
toString() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.TeamMemberSpec: 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.
toString() - Method in record class akka.javasdk.testkit.WebSocketRouteTester.WsConnection: Returns a string representation of this record class.
TRANSFER_TASK - Static variable in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Tool name for transferring a task (member side).
transferTask(String, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the transfer_task tool.
transferTask(String, String, String) - Static method in class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools: Creates a TestModelProvider.ToolInvocationRequest for the transfer_task tool with a specific backlog ID.
type() - Method in record class akka.javasdk.testkit.TestModelProvider.AutonomousAgentTools.ParticipantRef: Returns the value of the type record component.

U

UserMessage(String) - Constructor for record class akka.javasdk.testkit.TestModelProvider.UserMessage
UserMessage(List<MessageContent>) - 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.ObjectStorageBucketConfig.GcsWorkloadIdentity: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class akka.javasdk.testkit.ObjectStorageBucketConfig.S3WorkloadIdentity: Returns the enum constant of this class with the specified name.
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.ObjectStorageBucketConfig.GcsWorkloadIdentity: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class akka.javasdk.testkit.ObjectStorageBucketConfig.S3WorkloadIdentity: Returns an array containing the constants of this enum class, in the order they are declared.
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

WebSocketRouteTester - Interface in akka.javasdk.testkit

WebSocketRouteTester.WsConnection<T> - Record Class in akka.javasdk.testkit

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.

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

Enable all components to run, overriding any disabled components from ServiceSetup.disabledComponents().

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

Mock the incoming events flow from an EventSourcedEntity.

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

withKeyValueEntityIncomingMessages(Class<? extends KeyValueEntity<?>>) - Method in class akka.javasdk.testkit.TestKit.Settings

Mock the incoming messages flow from a KeyValueEntity.

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

withMessageSelector(Function<List<TestModelProvider.InputMessage>, TestModelProvider.InputMessage>) - Method in class akka.javasdk.testkit.TestModelProvider

Configures a custom message selector that determines which input message from the current turn is passed to response predicates.

withMetadata(Metadata) - Method in class akka.javasdk.testkit.ConsumerTestKit.MethodRef

withMetadata(Metadata) - Method in class akka.javasdk.testkit.ConsumerTestKit.MethodRef1

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

withMetadata(Metadata) - Method in class akka.javasdk.testkit.TimedActionTestkit.MethodRef

withMetadata(Metadata) - Method in class akka.javasdk.testkit.TimedActionTestkit.MethodRef1

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

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

withMockedGrpcService(String, Class<T>, T) - Method in class akka.javasdk.testkit.TestKit.Settings

Mock a gRPC service for calls made through GrpcClientProvider.grpcClientFor(Class, String) with the given service name and generated service client interface.

withMockedHttpService(String, Function<HttpRequest, HttpResponse>) - Method in class akka.javasdk.testkit.TestKit.Settings

Mock an HTTP service for calls made through HttpClientProvider.httpClientFor(String) with the given service name.

withModelProvider(Class<?>, ModelProvider) - Method in class akka.javasdk.testkit.TestKit.Settings

Override the model provider for an Agent or

invalid reference

AutonomousAgent

component.

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

Add a named object-storage bucket for use in dev mode / integration tests.

withOverriddenDisabledComponents(Set<Class<?>>) - Method in class akka.javasdk.testkit.TestKit.Settings

Disable components from running, useful for testing components in isolation.

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).

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

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

Capture the outgoing messages produced by a @Produce.ServiceStream for test assertions.

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

Mock the incoming state updates flow from a Workflow.

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

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

wsBinaryConnection(String) - Method in interface akka.javasdk.testkit.WebSocketRouteTester

WsConnection(TestPublisher.Probe<T>, TestSubscriber.Probe<T>) - Constructor for record class akka.javasdk.testkit.WebSocketRouteTester.WsConnection

Creates an instance of a WsConnection record class.

wsTextConnection(String) - Method in interface akka.javasdk.testkit.WebSocketRouteTester

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