WorkflowOutboundCallsInterceptor
extends
Interceptor
in
Interceptor for outbound workflow calls.
It's recommended to use WorkflowOutboundCallsInterceptorTrait when implementing this interface because the interface might be extended in the future. The trait will provide forward compatibility.
class MyWorkflowOutboundCallsInterceptor implements WorkflowOutboundCallsInterceptor
{
use WorkflowOutboundCallsInterceptorTrait;
public function executeActivity(
ExecuteActivityInput $input,
callable $next,
): PromiseInterface {
error_log('Calling activity: ' . $input->type);
return $next($input);
}
}
Table of Contents
Methods
- await() : PromiseInterface
- awaitWithTimeout() : PromiseInterface
- cancelExternalWorkflow() : PromiseInterface
- complete() : PromiseInterface
- continueAsNew() : PromiseInterface
- executeActivity() : PromiseInterface
- executeChildWorkflow() : PromiseInterface
- executeLocalActivity() : PromiseInterface
- getVersion() : PromiseInterface
- panic() : PromiseInterface
- sideEffect() : mixed
- Intercept {@see SideEffectInput::$callable} execution.
- signalExternalWorkflow() : PromiseInterface
- timer() : PromiseInterface
- upsertSearchAttributes() : PromiseInterface
Methods
await()
public
await(AwaitInput $input, callable(AwaitInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : AwaitInput
- $next : callable(AwaitInput): PromiseInterface
Return values
PromiseInterfaceawaitWithTimeout()
public
awaitWithTimeout(AwaitWithTimeoutInput $input, callable(AwaitWithTimeoutInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : AwaitWithTimeoutInput
- $next : callable(AwaitWithTimeoutInput): PromiseInterface
Return values
PromiseInterfacecancelExternalWorkflow()
public
cancelExternalWorkflow(CancelExternalWorkflowInput $input, callable(CancelExternalWorkflowInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : CancelExternalWorkflowInput
- $next : callable(CancelExternalWorkflowInput): PromiseInterface
Return values
PromiseInterfacecomplete()
public
complete(CompleteInput $input, callable(CompleteInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : CompleteInput
- $next : callable(CompleteInput): PromiseInterface
Return values
PromiseInterfacecontinueAsNew()
public
continueAsNew(ContinueAsNewInput $input, callable(ContinueAsNewInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : ContinueAsNewInput
- $next : callable(ContinueAsNewInput): PromiseInterface
Return values
PromiseInterfaceexecuteActivity()
public
executeActivity(ExecuteActivityInput $input, callable(ExecuteActivityInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : ExecuteActivityInput
- $next : callable(ExecuteActivityInput): PromiseInterface
Return values
PromiseInterfaceexecuteChildWorkflow()
public
executeChildWorkflow(ExecuteChildWorkflowInput $input, callable(ExecuteChildWorkflowInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : ExecuteChildWorkflowInput
- $next : callable(ExecuteChildWorkflowInput): PromiseInterface
Return values
PromiseInterfaceexecuteLocalActivity()
public
executeLocalActivity(ExecuteLocalActivityInput $input, callable(ExecuteLocalActivityInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : ExecuteLocalActivityInput
- $next : callable(ExecuteLocalActivityInput): PromiseInterface
Return values
PromiseInterfacegetVersion()
public
getVersion(GetVersionInput $input, callable(GetVersionInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : GetVersionInput
- $next : callable(GetVersionInput): PromiseInterface
Return values
PromiseInterfacepanic()
public
panic(PanicInput $input, callable(PanicInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : PanicInput
- $next : callable(PanicInput): PromiseInterface
Return values
PromiseInterfacesideEffect()
Intercept {@see SideEffectInput::$callable} execution.
public
sideEffect(SideEffectInput $input, callable(SideEffectInput): mixed $next) : mixed
Parameters
- $input : SideEffectInput
- $next : callable(SideEffectInput): mixed
Return values
mixed —The result of the callable execution.
signalExternalWorkflow()
public
signalExternalWorkflow(SignalExternalWorkflowInput $input, callable(SignalExternalWorkflowInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : SignalExternalWorkflowInput
- $next : callable(SignalExternalWorkflowInput): PromiseInterface
Return values
PromiseInterfacetimer()
public
timer(TimerInput $input, callable(TimerInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : TimerInput
- $next : callable(TimerInput): PromiseInterface
Return values
PromiseInterfaceupsertSearchAttributes()
public
upsertSearchAttributes(UpsertSearchAttributesInput $input, callable(UpsertSearchAttributesInput): PromiseInterface $next) : PromiseInterface
Parameters
- $input : UpsertSearchAttributesInput
- $next : callable(UpsertSearchAttributesInput): PromiseInterface