Class CacheQueue

Queue implementation that uses the configured cache driver as a queue.

Hierarchy

Queue
- CacheQueue

Index

Constructors

Properties

bus cache name serial

Accessors

queueIdentifier

Methods

dispatch pop push

Constructors

constructor

new CacheQueue(name: string): CacheQueue
Parameters
- name: string
Returns CacheQueue
Inherited from Queue.constructor
- Defined in src/support/bus/queue/Queue.ts:13

Properties

`Protected` `Readonly` bus

bus: Bus<Event>

`Protected` `Readonly` cache

cache: Cache

`Readonly` name

name: string

`Protected` `Readonly` serial

serial: Serialization

Accessors

`Protected` queueIdentifier

get queueIdentifier(): string
Returns string
- Defined in src/support/bus/queue/CacheQueue.ts:18

Methods

dispatch

dispatch<T>(item: T): Promise<void>
Type Parameters
- T extends Queueable
Parameters
- item: T
Returns Promise<void>
Inherited from Queue.dispatch
- Defined in src/support/bus/queue/Queue.ts:17

pop

pop(): Promise<Maybe<ShouldQueue<Queueable>>>
Returns Promise<Maybe<ShouldQueue<Queueable>>>
Overrides Queue.pop
- Defined in src/support/bus/queue/CacheQueue.ts:27

`Protected` push

push<T>(item: ShouldQueue<T>): Promise<void>
Type Parameters
- T extends Queueable
Parameters
- item: ShouldQueue<T>
Returns Promise<void>
Overrides Queue.push
- Defined in src/support/bus/queue/CacheQueue.ts:22