@sourceloop/task-service / Exports / EventProcessorService

Class: EventProcessorService

Implements

• IEventProcessor

Table of contents

Constructors

• constructor

Properties

• ctx
• filter
• incoming
• logger

Methods

• _triggerWorkflow
• handle

Constructors

constructor

• new EventProcessorService(ctx, filter, logger)

Parameters

Name	Type
ctx	Context
filter	EventFilter
logger	ILogger

Defined in

services/task-service/src/services/event-processor.service.ts:17

Properties

ctx

• Private Readonly ctx: Context

Defined in

services/task-service/src/services/event-processor.service.ts:19

---

filter

• Private Readonly filter: EventFilter

Defined in

services/task-service/src/services/event-processor.service.ts:21

---

incoming

• incoming: IIncomingConnector<IEvent<any>>

Defined in

services/task-service/src/services/event-processor.service.ts:16

---

logger

• Private Readonly logger: ILogger

Defined in

services/task-service/src/services/event-processor.service.ts:23

Methods

_triggerWorkflow

▸ Private _triggerWorkflow(workflowKey, payload, context): Promise<void>

Parameters

Name	Type
workflowKey	string
payload	AnyObject
context	Context

Returns

Promise<void>

Defined in

services/task-service/src/services/event-processor.service.ts:68

---

handle

▸ handle(event): Promise<void>

Parameters

Name	Type
event	IEvent<any>

Returns

Promise<void>

Implementation of

IEventProcessor.handle

Defined in

services/task-service/src/services/event-processor.service.ts:26