Fake Mirrors
    Preparing search index...

    Class RedisProducerConnector

    Redis-based producer connector implementation.

    Uses the ioredis client to manage connections for the Bull queue producer.

    https://github.com/redis/ioredis - ioredis documentation

    Depends:

    import { DIContainer } from '@famir/common'
    import {
      PRODUCER_CONNECTOR,
      ProducerConnector,
      RedisProducerConnector,
      RedisProducerConnection,
    } from '@famir/producer'

    // Get container singleton
    const container = DIContainer.getInstance()

    // Register dependency in container
    RedisProducerConnector.register(container)

    // Resolve dependency from container
    const connector = container.resolve<ProducerConnector>(PRODUCER_CONNECTOR)

    // Connect to Redis
    await connector.connect()

    // Get underlying Redis connection
    const connection = connector.getConnection<RedisProducerConnection>()

    //  Close connection
    await connector.close()

    Implements

    • Gracefully closes a connection to the producer.

      This method should be called during application shutdown to ensure all pending operations are completed and resources are released.

      Returns Promise<void>

      BootstrapError If the connection cannot be closed properly.

    • Retrieves the underlying producer connection.

      This method uses a type assertion to return the connection as the requested type. It is the caller's responsibility to ensure the correct type is used.

      Type Parameters

      • T

        The expected type of the producer connection.

      Returns T

      The producer connection cast to type T.

    Constructors
    Methods