hub / github.com/FlowiseAI/Flowise / setupAllQueues

Method setupAllQueues

packages/server/src/queue/QueueManager.ts:117–183 · view source on GitHub ↗

({
        componentNodes,
        telemetry,
        cachePool,
        appDataSource,
        abortControllerPool,
        usageCacheManager,
        identityManager,
        serverAdapter
    }: {
        componentNodes: IComponentNodes
        telemetry: Telemetry
        cachePool: CachePool
        appDataSource: DataSource
        abortControllerPool: AbortControllerPool
        usageCacheManager: UsageCacheManager
        identityManager: IdentityManager
        serverAdapter?: ExpressAdapter
    })

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 2

initDatabaseMethod · 0.80

runMethod · 0.80

Calls 5

registerQueueMethod · 0.95

getQueueNameMethod · 0.95

getQueueMethod · 0.95

Tested by

no test coverage detected