queue.Interface.QueueServiceContract

@sclable/nestjs-libs / queue / QueueServiceContract

Interface: QueueServiceContract

Defined in: packages/queue/src/contracts/queue-service.contract.ts:3

Methods

addConsumer()

addConsumer<PayloadType>(queueName, consumer): Promise<void>

Defined in: packages/queue/src/contracts/queue-service.contract.ts:5

Type Parameters

PayloadType

PayloadType

Parameters

queueName

string

consumer

(msg) => void | Promise<void>

Returns

Promise<void>

---

sendMessage()

sendMessage<PayloadType>(queueName, payload): Promise<void>

Defined in: packages/queue/src/contracts/queue-service.contract.ts:4

Type Parameters

PayloadType

PayloadType

Parameters

queueName

string

payload

PayloadType

Returns

Promise<void>