Method constructor

packages/cli/src/util/dev/queue-broker.ts:95–130

(
    services: ExperimentalService[],
    private getServiceOrigin: (name: string) => string | null
  )

  private tickTimer: ReturnType<typeof setInterval>;

  constructor(
    services: ExperimentalService[],
    private getServiceOrigin: (name: string) => string | null
  ) {
    for (const service of services) {
      if (!isQueueBackedService(service)) continue;

      const topicConfigs = getServiceQueueTopicConfigs(service);
      for (const topicConfig of topicConfigs) {
        const topicPattern = topicConfig.topic;
        const id = `${service.name}::${topicPattern}`;
        const group: ConsumerGroup = {
          id,
          name: service.name,
          topicPattern,
          topicRegex: topicPatternToRegex(topicPattern),
          serviceOriginFn: () => this.getServiceOrigin(service.name),
          retryAfterMs:
            topicConfig.retryAfterSeconds !== undefined
              ? topicConfig.retryAfterSeconds * 1000
              : DEFAULT_RETRY_AFTER,
          maxDeliveries: DEFAULT_MAX_DELIVERIES,
          initialDelayMs:
            topicConfig.initialDelaySeconds !== undefined
              ? topicConfig.initialDelaySeconds * 1000
              : DEFAULT_INITIAL_DELAY,
        };

        this.consumerGroups.push(group);
        this.deliveryState.set(group.id, new Map());
      }
    }

    this.tickTimer = setInterval(() => this.tick(), TICK_INTERVAL);
    this.tickTimer.unref();
  }

  enqueue(
    queueName: string,