Class RedisConsumeConnector

Redis consume connector implementation

See

Implements

ConsumeConnector

Constructors

constructor

new RedisConsumeConnector(
config: Config<BullConsumeConfig>,
logger: Logger,
): RedisConsumeConnector
Parameters
- config: Config<BullConsumeConfig>
- logger: Logger
Returns RedisConsumeConnector
- Defined in packages/consume/src/redis-consume-connector.ts:33

Methods

close

close(): Promise<void>
Close connection

Returns Promise<void>
Implementation of ConsumeConnector.close
- Defined in packages/consume/src/redis-consume-connector.ts:65

getConnection

getConnection<T>(): T
Get connection object
Type Parameters
- T
Returns T
Implementation of ConsumeConnector.getConnection
- Defined in packages/consume/src/redis-consume-connector.ts:55

`Static`register

register(container: DIContainer): void
Register dependency
Parameters
- container: DIContainer
Returns void
- Defined in packages/consume/src/redis-consume-connector.ts:23