Package software.amazon.lambda.durable.operation

Class CallbackOperation<T>

java.lang.Object

software.amazon.lambda.durable.operation.BaseDurableOperation

software.amazon.lambda.durable.operation.SerializableDurableOperation<T>

software.amazon.lambda.durable.operation.CallbackOperation<T>

All Implemented Interfaces:

DurableCallbackFuture<T>, DurableFuture<T>

public class CallbackOperation<T>
extends SerializableDurableOperation<T>
implements DurableCallbackFuture<T>

Durable operation for creating and waiting on external callbacks.

Nested Class Summary

Nested classes/interfaces inherited from class software.amazon.lambda.durable.operation.SerializableDurableOperation

SerializableDurableOperation.SerializedResult<T>

Field Summary

Fields inherited from class software.amazon.lambda.durable.operation.BaseDurableOperation

completionFuture, executionManager, isVirtual, parentOperation, replayCompletedOperation

Constructor Summary

Constructors

Constructor	Description
CallbackOperation(OperationIdentifier operationIdentifier, TypeToken<T> resultTypeToken, CallbackConfig config, DurableContextImpl durableContext)

Method Summary

Modifier and Type	Method	Description
String	callbackId()	Returns the unique identifier for this callback.
T	get()	Blocks until the operation completes and returns the result.
protected void	replay(software.amazon.awssdk.services.lambda.model.Operation existing)	Replays the operation.
protected void	start()	Starts the operation.

Methods inherited from class software.amazon.lambda.durable.operation.SerializableDurableOperation

deserializeException, deserializeResult, serDesContext, serializeAndDeserializeResult, serializeException

Methods inherited from class software.amazon.lambda.durable.operation.BaseDurableOperation

deregisterActiveThread, execute, extractErrorFromOperation, fireOnOperationEnd, getChildOperations, getCompletionFuture, getContext, getCurrentThreadContext, getErrorObject, getName, getOperation, getOperationId, getRunningUserHandler, getSubType, getType, interruptRunningUserHandler, isOperationCompleted, isRunningUserHandlerOwner, markAlreadyCompleted, onCheckpointComplete, pollForOperationUpdates, pollForOperationUpdates, processCheckpointUpdate, registerActiveThread, runUserFunction, runUserHandler, sendOperationUpdate, sendOperationUpdateAsync, terminateExecution, terminateExecutionWithIllegalDurableOperationException, validateReplay, waitForFirstOperationCompletion, waitForOperationCompletion

Methods inherited from class java.lang.Object

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

Constructor Details

CallbackOperation

public CallbackOperation(OperationIdentifier operationIdentifier,
 TypeToken<T> resultTypeToken,
 CallbackConfig config,
 DurableContextImpl durableContext)

Method Details

callbackId

public String callbackId()

Description copied from interface: DurableCallbackFuture

Returns the unique identifier for this callback.

External systems use this ID to send callback results back to the durable execution.

Specified by:

callbackId in interface DurableCallbackFuture<T>

Returns:

the callback ID

start

protected void start()

Starts the operation.

Specified by:

start in class BaseDurableOperation

replay

protected void replay(software.amazon.awssdk.services.lambda.model.Operation existing)

Replays the operation.

Specified by:

replay in class BaseDurableOperation

Parameters:

existing - the checkpointed operation state

get

public T get()

Description copied from interface: DurableFuture

Blocks until the operation completes and returns the result.

This delegates to operation.get() which handles: - Thread deregistration (allows suspension) - Thread reactivation (resumes execution) - Result retrieval

Specified by:

get in interface DurableFuture<T>

Specified by:

get in class SerializableDurableOperation<T>

Returns:

the operation result