Class QueueEventsProducer

closing

keys

Readonlyname

opts

ReadonlyqualifiedName

toKey

client

• get client(): Promise<RedisClient>

  Returns a promise that resolves to a redis client. Normally used only by subclasses.

  Returns Promise<RedisClient>

redisVersion

• get redisVersion(): string

  Returns the version of the Redis instance the client is connected to,

  Returns string

disconnect

• disconnect(): Promise<void>

  Force disconnects a connection.

  Returns Promise<void>

emit

• emit(event: string | symbol, ...args: any[]): boolean

  Emits an event. Normally used by subclasses to emit events.

  Parameters

  • event: string | symbol

    The emitted event.
  • ...args: any[]

  Returns boolean

trace

• trace<T>(
      spanKind: SpanKind,
      operation: string,
      destination: string,
      callback: (span?: Span, dstPropagationMetadata?: string) => T | Promise<T>,
      srcPropagationMetadata?: string,
  ): Promise<T | Promise<T>>

  Wraps the code with telemetry and provides a span for configuration.

  Type Parameters

  • T

  Parameters

  • spanKind: SpanKind

    kind of the span: Producer, Consumer, Internal
  • operation: string

    operation name (such as add, process, etc)
  • destination: string

    destination name (normally the queue name)
  • callback: (span?: Span, dstPropagationMetadata?: string) => T | Promise<T>

    code to wrap with telemetry
  • OptionalsrcPropagationMetadata: string

  Returns Promise<T | Promise<T>>

waitUntilReady

• waitUntilReady(): Promise<RedisClient>

  Returns Promise<RedisClient>