PURISTA API

---

PURISTA API / @purista/core / DefaultQueueBridge

Class: DefaultQueueBridge

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:31

Implements

• QueueBridge

Constructors

Constructor

new DefaultQueueBridge(options?): DefaultQueueBridge

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:64

Parameters

options?

DefaultQueueBridgeOptions

Returns

DefaultQueueBridge

Properties

capabilities

readonly capabilities: QueueBridgeCapabilities

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:34

Implementation of

QueueBridge.capabilities

---

instanceId

readonly instanceId: string

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:55

Implementation of

QueueBridge.instanceId

---

name

readonly name: "DefaultQueueBridge" = 'DefaultQueueBridge'

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:32

Implementation of

QueueBridge.name

Methods

ack()

ack(queueName, leaseId): Promise<void>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:175

Parameters

queueName

string

leaseId

string

Returns

Promise<void>

Implementation of

QueueBridge.ack

---

destroy()

destroy(): Promise<void>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:81

Returns

Promise<void>

Implementation of

QueueBridge.destroy

---

enqueue()

enqueue(options): Promise<QueueEnqueueResult>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:87

Parameters

options

QueueEnqueueOptions<unknown, unknown>

Returns

Promise<QueueEnqueueResult>

Implementation of

QueueBridge.enqueue

---

extendLease()

extendLease(queueName, leaseId, extensionMs): Promise<void>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:165

Parameters

queueName

string

leaseId

string

extensionMs

number

Returns

Promise<void>

Implementation of

QueueBridge.extendLease

---

inspectLeases()

inspectLeases(_queueName, _options?): Promise<QueueLeaseInspectionRecord[]>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:264

Parameters

_queueName

string

_options?

QueueDeadLetterListOptions

Returns

Promise<QueueLeaseInspectionRecord[]>

Implementation of

QueueBridge.inspectLeases

---

isHealthy()

isHealthy(): Promise<boolean>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:77

Returns

Promise<boolean>

Implementation of

QueueBridge.isHealthy

---

isReady()

isReady(): Promise<boolean>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:73

Returns

Promise<boolean>

Implementation of

QueueBridge.isReady

---

leaseNext()

leaseNext(queueName, _opts?): Promise<QueueLease | undefined>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:119

Parameters

queueName

string

_opts?

QueueLeaseOptions

Returns

Promise<QueueLease | undefined>

Implementation of

QueueBridge.leaseNext

---

metrics()

metrics(queueName): Promise<QueueMetrics>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:271

Parameters

queueName

string

Returns

Promise<QueueMetrics>

Implementation of

QueueBridge.metrics

---

moveToDeadLetter()

moveToDeadLetter(queueName, message, reason?): Promise<void>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:213

Parameters

queueName

string

message

QueueMessage

reason?

string

Returns

Promise<void>

Implementation of

QueueBridge.moveToDeadLetter

---

nack()

nack(queueName, leaseId, request): Promise<void>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:183

Parameters

queueName

string

leaseId

string

request

QueueRetryRequest

Returns

Promise<void>

Implementation of

QueueBridge.nack

---

peekDeadLetter()

peekDeadLetter(queueName, options?): Promise<QueueMessage[]>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:229

Parameters

queueName

string

options?

QueueDeadLetterListOptions

Returns

Promise<QueueMessage[]>

Implementation of

QueueBridge.peekDeadLetter

---

purgeDeadLetter()

purgeDeadLetter(queueName): Promise<number>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:258

Parameters

queueName

string

Returns

Promise<number>

Implementation of

QueueBridge.purgeDeadLetter

---

redriveDeadLetter()

redriveDeadLetter(queueName, options?): Promise<number>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:236

Parameters

queueName

string

options?

QueueDeadLetterRedriveOptions

Returns

Promise<number>

Implementation of

QueueBridge.redriveDeadLetter

---

start()

start(): Promise<void>

Defined in: DefaultQueueBridge/DefaultQueueBridge.impl.ts:71

Returns

Promise<void>

Implementation of

QueueBridge.start