Class ConsumeRouter

Represents a consume router

Constructors

constructor

new ConsumeRouter(
    logger: Logger,
    specs: ConsumeSpecs,
    assets: ConsumeAssets,
): ConsumeRouter
Parameters
- logger: Logger
- specs: ConsumeSpecs
- assets: ConsumeAssets
Returns ConsumeRouter
- Defined in packages/consume/src/consume-router.ts:45

Accessors

isActive

get isActive(): boolean
Check if router is active

Returns boolean
- Defined in packages/consume/src/consume-router.ts:62

Methods

activate

activate(): void
Activate router

Returns void
- Defined in packages/consume/src/consume-router.ts:69

addProcessor

addProcessor(
    queueName: string,
    jobName: string,
    processor: ConsumeProcessor,
): void
Add processor
Parameters
- queueName: string
- jobName: string
- processor: ConsumeProcessor
Returns void
- Defined in packages/consume/src/consume-router.ts:96

getAsset

getAsset(assetName: string): string | undefined
Get asset by name
Parameters
- assetName: string
Returns string | undefined
- Defined in packages/consume/src/consume-router.ts:89

getProcessor

getProcessor(queueName: string, jobName: string): ConsumeProcessor
Get processor by name
Parameters
- queueName: string
- jobName: string
Returns ConsumeProcessor
- Defined in packages/consume/src/consume-router.ts:118

getSpec

getSpec(queueName: string): ConsumeSpec
Get spec by queueName
Parameters
- queueName: string
Returns ConsumeSpec
- Defined in packages/consume/src/consume-router.ts:76

`Static`register

register(
    container: DIContainer,
    specs: ConsumeSpecs,
    assets: ConsumeAssets,
): void
Register dependency
Parameters
- container: DIContainer
- specs: ConsumeSpecs
- assets: ConsumeAssets
Returns void
- Defined in packages/consume/src/consume-router.ts:24

`Static`resolve

resolve(container: DIContainer): ConsumeRouter
Resolve dependency
Parameters
- container: DIContainer
Returns ConsumeRouter
- Defined in packages/consume/src/consume-router.ts:39