Class BaseActorWorker

Hierarchy

BaseActorWorker

Implements

ActorWorker

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new BaseActorWorker(workflowClient: WorkflowClient, domain: string, appContainer: Container, activityPoller: TaskPollerObservable<ActivityTask>, bindings: Binding[], logger: Logger): BaseActorWorker

- Defined in core/actor/worker/actor-worker.ts:25
Parameters
- workflowClient: WorkflowClient
- domain: string
- appContainer: Container
- activityPoller: TaskPollerObservable<ActivityTask>
- bindings: Binding[]
- logger: Logger
Returns BaseActorWorker

Properties

Private activityPoller

activityPoller: TaskPollerObservable<ActivityTask>

Private appContainer

appContainer: Container

Private bindings

bindings: Binding[]

Private domain

domain: string

Private logger

logger: Logger

Private workflowClient

workflowClient: WorkflowClient

Methods

Private activityDefinitionToRegisterActivityTpeInput

activityDefinitionToRegisterActivityTpeInput(definition: ActivityDefinition): RegisterActivityTypeInput

- Defined in core/actor/worker/actor-worker.ts:36
Parameters
- definition: ActivityDefinition
Returns RegisterActivityTypeInput

createStub

createStub(): LocalStub

- Defined in core/actor/worker/actor-worker.ts:70
Returns LocalStub

register

register(): Observable<any>

Implementation of ActorWorker.register
- Defined in core/actor/worker/actor-worker.ts:63
Returns Observable<any>

Private registerActivity

registerActivity(definition: ActivityDefinition): Observable<any>

- Defined in core/actor/worker/actor-worker.ts:51
Parameters
- definition: ActivityDefinition
Returns Observable<any>

respondActivityFinished

respondActivityFinished(taskToken: string, result: string): Observable<any>

- Defined in core/actor/worker/actor-worker.ts:74
Parameters
- taskToken: string
- result: string
Returns Observable<any>

respondActivityTaskFailed

respondActivityTaskFailed(taskToken: string, details: string, reason: string): Observable<any>

- Defined in core/actor/worker/actor-worker.ts:84
Parameters
- taskToken: string
- details: string
- reason: string
Returns Observable<any>

startWorker

startWorker(): void

Implementation of ActorWorker.startWorker
- Defined in core/actor/worker/actor-worker.ts:95
Returns void

Generated using TypeDoc